@ SuppressWarnings ( { "ThrowableInstanceNeverThrown" } ) private void handleException ( Throwable e , ResultSender < Serializable > resultSender , String queryString ) { logger . error ( "Failed to execute bucket oriented query" + ( queryString != null ? ": " + queryString : "." ) , e ) ; resultSender . sendException ( new FunctionException ( e . getMessage ( ) ) ) ; }
Handles exceptions during query execution .