You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/11/02 02:45:23 UTC
[iotdb] branch master updated: Add debug level judgement firstly (#7872)
This is an automated email from the ASF dual-hosted git repository.
hui 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 6823e6ec57 Add debug level judgement firstly (#7872)
6823e6ec57 is described below
commit 6823e6ec5710b2da615ac553155174dde7b959de
Author: Jackie Tien <ja...@gmail.com>
AuthorDate: Wed Nov 2 10:45:17 2022 +0800
Add debug level judgement firstly (#7872)
---
.../consensus/statemachine/SchemaRegionStateMachine.java | 2 +-
.../execution/fragment/FragmentInstanceStateMachine.java | 14 ++++++++------
.../apache/iotdb/db/mpp/plan/execution/QueryExecution.java | 2 +-
3 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/SchemaRegionStateMachine.java b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/SchemaRegionStateMachine.java
index 6b03b6dd72..c324b35d07 100644
--- a/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/SchemaRegionStateMachine.java
+++ b/server/src/main/java/org/apache/iotdb/db/consensus/statemachine/SchemaRegionStateMachine.java
@@ -86,7 +86,7 @@ public class SchemaRegionStateMachine extends BaseStateMachine {
logger.error(e.getMessage());
return null;
}
- logger.info(
+ logger.debug(
"SchemaRegionStateMachine[{}]: Execute read plan: FragmentInstance-{}",
schemaRegion.getSchemaRegionId(),
fragmentInstance.getId());
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
index d19e2c7f35..2071fcc8b2 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
@@ -75,12 +75,14 @@ public class FragmentInstanceStateMachine {
instanceState =
new StateMachine<>(
"FragmentInstance " + fragmentInstanceId, executor, RUNNING, TERMINAL_INSTANCE_STATES);
- instanceState.addStateChangeListener(
- newState -> {
- try (SetThreadName threadName = new SetThreadName(fragmentInstanceId.getFullId())) {
- LOGGER.info("[StateChanged] To {}", newState);
- }
- });
+ if (LOGGER.isDebugEnabled()) {
+ instanceState.addStateChangeListener(
+ newState -> {
+ try (SetThreadName threadName = new SetThreadName(fragmentInstanceId.getFullId())) {
+ LOGGER.debug("[StateChanged] To {}", newState);
+ }
+ });
+ }
}
public long getCreatedTime() {
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 4f0cff7b29..88b954af7d 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
@@ -297,7 +297,7 @@ public class QueryExecution implements IQueryExecution {
public void doDistributedPlan() {
DistributionPlanner planner = new DistributionPlanner(this.analysis, this.logicalPlan);
this.distributedPlan = planner.planFragments();
- if (isQuery()) {
+ if (isQuery() && logger.isDebugEnabled()) {
logger.debug(
"distribution plan done. Fragment instance count is {}, details is: \n {}",
distributedPlan.getInstances().size(),