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/11/01 09:30:41 UTC
[iotdb] 01/01: Change log level
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch DebugLog
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 723b8a519f1e1367c5d96f6f5ae73df730b7b49f
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Nov 1 17:27:50 2022 +0800
Change log level
---
.../db/mpp/execution/exchange/MPPDataExchangeManager.java | 10 +++++-----
.../org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java | 2 +-
2 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
index 52a4d5bbc1..d0ee58996c 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
@@ -121,7 +121,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
e.getEndSequenceId(),
e.getSourceFragmentInstanceId());
if (!sinkHandles.containsKey(e.getSourceFragmentInstanceId())) {
- logger.warn(
+ logger.debug(
"received ACK event but target FragmentInstance[{}] is not found.",
e.getSourceFragmentInstanceId());
return;
@@ -160,7 +160,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
// may
// have already been stopped. For example, in the query whit LimitOperator, the downstream
// FragmentInstance may be finished, although the upstream is still working.
- logger.warn(
+ logger.debug(
"received NewDataBlockEvent but the downstream FragmentInstance[{}] is not found",
e.getTargetFragmentInstanceId());
return;
@@ -194,7 +194,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
.get(e.getTargetFragmentInstanceId())
.get(e.getTargetPlanNodeId())
.isFinished()) {
- logger.warn(
+ logger.debug(
"received onEndOfDataBlockEvent but the downstream FragmentInstance[{}] is not found",
e.getTargetFragmentInstanceId());
return;
@@ -225,7 +225,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
|| !sourceHandles
.get(sourceHandle.getLocalFragmentInstanceId())
.containsKey(sourceHandle.getLocalPlanNodeId())) {
- logger.warn("[ScHListenerAlreadyReleased]");
+ logger.debug("[ScHListenerAlreadyReleased]");
} else {
sourceHandles
.get(sourceHandle.getLocalFragmentInstanceId())
@@ -286,7 +286,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
private void removeFromMPPDataExchangeManager(ISinkHandle sinkHandle) {
if (sinkHandles.remove(sinkHandle.getLocalFragmentInstanceId()) == null) {
- logger.warn("[RemoveNoSinkHandle]");
+ logger.debug("[RemoveNoSinkHandle]");
} else {
logger.debug("[RemoveSinkHandle]");
}
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 4875612f7c..4f0cff7b29 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
@@ -363,7 +363,7 @@ public class QueryExecution implements IQueryExecution {
stateMachine.getFailureMessage(), TSStatusCode.QUERY_PROCESS_ERROR.getStatusCode());
}
} else if (resultHandle.isFinished()) {
- logger.info("[ResultHandleFinished]");
+ logger.debug("[ResultHandleFinished]");
stateMachine.transitionToFinished();
return Optional.empty();
}