This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch add_log_event in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3bc080754dceb5080c3b6ec46c5285c7af0205c6 Author: JackieTien97 <[email protected]> AuthorDate: Wed Sep 14 16:09:37 2022 +0800 chaneg log level and thread name --- .../org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java | 4 ++-- .../java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java index 93659d0661..4416cb84c9 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/DriverScheduler.java @@ -93,13 +93,13 @@ public class DriverScheduler implements IDriverScheduler, IService { public void start() throws StartupException { for (int i = 0; i < WORKER_THREAD_NUM; i++) { AbstractDriverThread t = - new DriverTaskThread("Worker-Thread-" + i, workerGroups, readyQueue, scheduler); + new DriverTaskThread("Query-Worker-Thread-" + i, workerGroups, readyQueue, scheduler); threads.add(t); t.start(); } AbstractDriverThread t = new DriverTaskTimeoutSentinelThread( - "Sentinel-Thread", workerGroups, timeoutQueue, scheduler); + "Query-Sentinel-Thread", workerGroups, timeoutQueue, scheduler); threads.add(t); t.start(); } diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java index c15bffa607..48607b996f 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java @@ -339,7 +339,7 @@ public class QueryExecution implements IQueryExecution { // Once the resultHandle is finished, we should transit the state of this query to // FINISHED. // So that the corresponding cleanup work could be triggered. - logger.warn("[ResultHandleFinished]"); + logger.info("[ResultHandleFinished]"); stateMachine.transitionToFinished(); return Optional.empty(); }
