[iotdb] 01/01: Add Error log for ConfigExecution

[ja...@apache.org]

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

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

commit 3e3531953bcb04dca8516c146b60218b770e20cf
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Mon Sep 26 20:05:39 2022 +0800

    Add Error log for ConfigExecution
---
 .../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) {