You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/09/26 12:15:20 UTC
[iotdb] branch master updated: Add Error log for ConfigExecution (#7436)
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 <ja...@gmail.com>
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) {