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 <[email protected]> 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(); }
