This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 8ff428b0ae Add Error log for ConfigExecution (#7436)
8ff428b0ae is described below

commit 8ff428b0ae005aeb333306550fd373da7d8ad5f8
Author: Jackie Tien <[email protected]>
AuthorDate: Mon Sep 26 20:15:14 2022 +0800

    Add Error log for ConfigExecution (#7436)
---
 .../iotdb/db/mpp/plan/execution/config/ConfigExecution.java      | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigExecution.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigExecution.java
index be8a4491f1..c73ec144a1 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigExecution.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ConfigExecution.java
@@ -43,6 +43,8 @@ import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
 import jersey.repackaged.com.google.common.util.concurrent.SettableFuture;
 import org.jetbrains.annotations.NotNull;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.Optional;
 import java.util.concurrent.ExecutionException;
@@ -50,7 +52,9 @@ import java.util.concurrent.ExecutorService;
 
 public class ConfigExecution implements IQueryExecution {
 
-  private static IoTDBConfig config = 
IoTDBDescriptor.getInstance().getConfig();
+  private static final Logger LOGGER = 
LoggerFactory.getLogger(ConfigExecution.class);
+
+  private static final IoTDBConfig config = 
IoTDBDescriptor.getInstance().getConfig();
 
   private final MPPQueryContext context;
   private final ExecutorService executor;
@@ -116,7 +120,8 @@ public class ConfigExecution implements IQueryExecution {
     }
   }
 
-  public void fail(Throwable cause) {
+  private void fail(Throwable cause) {
+    LOGGER.error("Failures happened during running ConfigExecution.", cause);
     stateMachine.transitionToFailed(cause);
     ConfigTaskResult result;
     if (cause instanceof IoTDBException) {

Reply via email to