code: @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()));
      }
docs: Handles exceptions during query execution.
  
  @param e Exception to handle.
  @param resultSender of type ResultSender<Serializable>