GEODE-10231 : Add configuration for suppressing FunctionException log…

…ging Use Log4j Markers for FunctionException logs
apache · Apr 19, 2022 · 7f85a9a · 7f85a9a
1 parent f7eb735
commit 7f85a9a
Show file tree

Hide file tree

Showing 9 changed files with 65 additions and 10 deletions.
diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java
@@ -22,9 +22,12 @@
 import java.util.concurrent.TimeUnit;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 
 import org.apache.geode.InternalGemFireException;
 import org.apache.geode.SystemFailure;
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.annotations.internal.MakeNotStatic;
 import org.apache.geode.cache.LowMemoryException;
 import org.apache.geode.cache.TransactionException;
@@ -55,6 +58,9 @@
  */
 public abstract class AbstractExecution implements InternalExecution {
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  public static final int DEFAULT_CLIENT_FUNCTION_TIMEOUT = 0;
  private static final String CLIENT_FUNCTION_TIMEOUT_SYSTEM_PROPERTY =
@@ -504,7 +510,8 @@ private void handleException(Throwable functionException, final Function fn,
  ((InternalResultSender) sender).setException(functionException);
  }
  } else {
- logger.warn("Exception occurred on local node while executing Function:",
+ logger.warn(functionException instanceof FunctionException ? functionExceptionMarker : null,
+ "Exception occurred on local node while executing Function:",
  functionException);
  }
  }

diff --git a/...n/java/org/apache/geode/internal/cache/execute/DistributedRegionFunctionResultSender.java b/...n/java/org/apache/geode/internal/cache/execute/DistributedRegionFunctionResultSender.java
@@ -15,7 +15,10 @@
 package org.apache.geode.internal.cache.execute;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.cache.execute.Function;
 import org.apache.geode.cache.execute.FunctionException;
 import org.apache.geode.cache.execute.ResultCollector;
@@ -29,6 +32,9 @@
 public class DistributedRegionFunctionResultSender implements InternalResultSender {
 
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  DistributedRegionFunctionStreamingMessage msg = null;
 
@@ -224,7 +230,8 @@ public void setException(Throwable exception) {
  } else {
  ((LocalResultCollector) rc).setException(exception);
  // this.lastResult(exception);
- logger.info("Unexpected exception during function execution on local node Distributed Region",
+ logger.info(exception instanceof FunctionException ? functionExceptionMarker : null,
+ "Unexpected exception during function execution on local node Distributed Region",
  exception);
  }
  rc.endResults();

diff --git a/...ore/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java b/...ore/src/main/java/org/apache/geode/internal/cache/execute/MemberFunctionResultSender.java
@@ -16,7 +16,10 @@
 package org.apache.geode.internal.cache.execute;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.cache.execute.Function;
 import org.apache.geode.cache.execute.FunctionException;
 import org.apache.geode.cache.execute.ResultCollector;
@@ -31,6 +34,9 @@
 public class MemberFunctionResultSender implements InternalResultSender {
 
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  MemberFunctionStreamingMessage msg = null;
 
@@ -232,7 +238,8 @@ public void sendException(Throwable exception) {
  public void setException(Throwable exception) {
  ((LocalResultCollector) rc).setException(exception);
  // this.lastResult(exception);
- logger.info("Unexpected exception during function execution local member",
+ logger.info(exception instanceof FunctionException ? functionExceptionMarker : null,
+ "Unexpected exception during function execution local member",
  exception);
  rc.endResults();
  localLastResultReceived = true;

diff --git a/...n/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java b/...n/java/org/apache/geode/internal/cache/execute/PartitionedRegionFunctionResultSender.java
@@ -17,7 +17,10 @@
 
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.cache.execute.Function;
 import org.apache.geode.cache.execute.FunctionException;
 import org.apache.geode.cache.execute.ResultCollector;
@@ -42,6 +45,9 @@
 public class PartitionedRegionFunctionResultSender implements InternalResultSender {
 
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  PartitionedRegionFunctionStreamingMessage msg = null;
 
@@ -390,7 +396,8 @@ public void setException(Throwable exception) {
  serverSender.setException(exception);
  } else {
  ((LocalResultCollector) rc).setException(exception);
- logger.info("Unexpected exception during function execution on local node Partitioned Region",
+ logger.info(exception instanceof FunctionException ? functionExceptionMarker : null,
+ "Unexpected exception during function execution on local node Partitioned Region",
  exception);
  }
  rc.endResults();

diff --git a/...main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java b/...main/java/org/apache/geode/internal/cache/execute/ServerToClientFunctionResultSender.java
@@ -20,7 +20,10 @@
 import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.cache.execute.Function;
 import org.apache.geode.cache.execute.FunctionException;
 import org.apache.geode.cache.execute.ResultSender;
@@ -37,6 +40,9 @@
 
 public class ServerToClientFunctionResultSender implements ResultSender {
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  protected ChunkedMessage msg = null;
 
@@ -321,9 +327,9 @@ public synchronized void setException(Throwable exception) {
  }
  String exceptionMessage = exception.getMessage() != null ? exception.getMessage()
  : "Exception occurred during function execution";
- logger.warn(String.format("Exception on server while executing function : %s",
- fn),
- exception);
+ logger.warn(exception instanceof FunctionException ? functionExceptionMarker : null,
+ "Exception on server while executing function : {}", fn, exception);
+
  if (logger.isDebugEnabled()) {
  logger.debug("ServerToClientFunctionResultSender sending Function Exception : ");
  }

diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/BaseCommand.java
@@ -34,6 +34,8 @@
 import java.util.regex.Pattern;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
@@ -88,6 +90,9 @@
 
 public abstract class BaseCommand implements Command {
  protected static final Logger logger = LogService.getLogger();
+ @Immutable
+ protected static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
 
  @Immutable
  private static final byte[] OK_BYTES = new byte[] {0};

diff --git a/...src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java b/...src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction70.java
@@ -431,6 +431,10 @@ private void executeFunctionLocally(final Function fn, final FunctionContext cx,
  if (logger.isDebugEnabled()) {
  logger.debug("Exception on server while executing function: {}", fn, e);
  }
+ } catch (FunctionException e) {
+ stats.endFunctionExecutionWithException(startExecution, fn.hasResult());
+ logger.warn(functionExceptionMarker, "Exception on server while executing function: {}",
+ fn, e);
  } catch (Exception e) {
  stats.endFunctionExecutionWithException(startExecution, fn.hasResult());
  logger.warn("Exception on server while executing function: {}", fn, e);

diff --git a/...in/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java b/...in/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteRegionFunction66.java
@@ -220,9 +220,9 @@ public void cmdExecute(final @NotNull Message clientMessage,
  resultSender.setException(fe);
  } else {
  if (setLastResultReceived(resultSender)) {
- logger.warn(String.format("Exception on server while executing function : %s",
- function),
- fe);
+ logger.warn(functionExceptionMarker,
+ "Exception on server while executing function : {}",
+ function, fe);
  sendException(hasResult, clientMessage, message, serverConnection, fe);
  }
  }

diff --git a/...c/main/java/org/apache/geode/management/internal/cli/functions/UserFunctionExecution.java b/...c/main/java/org/apache/geode/management/internal/cli/functions/UserFunctionExecution.java
@@ -28,13 +28,17 @@
 import java.util.stream.Collectors;
 
 import org.apache.logging.log4j.Logger;
+import org.apache.logging.log4j.Marker;
+import org.apache.logging.log4j.MarkerManager;
 import org.apache.shiro.subject.Subject;
 
+import org.apache.geode.annotations.Immutable;
 import org.apache.geode.cache.Cache;
 import org.apache.geode.cache.Region;
 import org.apache.geode.cache.execute.Execution;
 import org.apache.geode.cache.execute.Function;
 import org.apache.geode.cache.execute.FunctionContext;
+import org.apache.geode.cache.execute.FunctionException;
 import org.apache.geode.cache.execute.FunctionService;
 import org.apache.geode.cache.execute.ResultCollector;
 import org.apache.geode.cache.query.RegionNotFoundException;
@@ -55,6 +59,10 @@
 public class UserFunctionExecution implements InternalFunction<Object[]> {
  private static final long serialVersionUID = 1L;
  private static final Logger logger = LogService.getLogger();
+ @Immutable
+ private static final Marker functionExceptionMarker =
+ MarkerManager.getMarker("FUNCTION_EXCEPTION_MARKER");
+
  protected static final String ID =
  "org.apache.geode.management.internal.cli.functions.UserFunctionExecution";
 
@@ -244,6 +252,10 @@ public void execute(FunctionContext<Object[]> context) {
  CliStrings.format(
  CliStrings.EXECUTE_FUNCTION__MSG__RESULT_COLLECTOR_0_NOT_FOUND_ERROR_1,
  resultCollectorName, e.getMessage())));
+ } catch (FunctionException e) {
+ logger.error(functionExceptionMarker, "error executing function {}", functionId, e);
+ context.getResultSender().lastResult(
+ new CliFunctionResult(context.getMemberName(), ERROR, "Exception: " + e.getMessage()));
  } catch (Exception e) {
  logger.error("error executing function " + functionId, e);
  context.getResultSender().lastResult(