public void onCompleted ( ) { mSerializingExecutor . execute ( ( ) -> { Preconditions . checkState ( mContext != null ) ; try { completeRequest ( mContext ) ; replySuccess ( ) ; } catch ( Exception e ) { LogUtils . warnWithException ( LOG , "Exception occurred while completing write request {}." , mContext . getRequest ( ) , e ) ; Throwables . throwIfUnchecked ( e ) ; abort ( new Error ( AlluxioStatusException . fromCheckedException ( e ) , true ) ) ; } } ) ; }
Handles request complete event .