[iotdb] branch DebugLog created (now 723b8a519f)

[ja...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a change to branch DebugLog
in repository https://gitbox.apache.org/repos/asf/iotdb.git


      at 723b8a519f Change log level

This branch includes the following new commits:

     new 723b8a519f Change log level

The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.

[iotdb] 01/01: Change log level

[ja...@apache.org]

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();
         }