[iotdb] branch master updated: Print sql and corresponding QueryId (#6319)

[xingtanzjr]

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

xingtanzjr 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 cba438a413 Print sql and corresponding QueryId (#6319)
cba438a413 is described below

commit cba438a41342e14e403904756fd5de2d9752073a
Author: Jackie Tien <jackietie...@gmail.com>
AuthorDate: Fri Jun 17 10:07:12 2022 +0800

    Print sql and corresponding QueryId (#6319)
---
 .../iotdb/db/mpp/execution/datatransfer/DataBlockManager.java       | 6 +++---
 server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java  | 3 +++
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
index 05748f7519..0db8bb2328 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManager.java
@@ -265,9 +265,9 @@ public class DataBlockManager implements IDataBlockManager {
     }
 
     private void removeFromDataBlockManager(ISinkHandle sinkHandle) {
-      logger.info("{} release resources of finished sink handle", sinkHandle);
+      logger.info("release resources of finished sink handle");
       if (!sinkHandles.containsKey(sinkHandle.getLocalFragmentInstanceId())) {
-        logger.info("{} resources already been released", sinkHandle);
+        logger.info("resources already been released");
       }
       sinkHandles.remove(sinkHandle.getLocalFragmentInstanceId());
     }
@@ -275,7 +275,7 @@ public class DataBlockManager implements IDataBlockManager {
     @Override
     public void onFailure(ISinkHandle sinkHandle, Throwable t) {
       // TODO: (xingtanzjr) should we remove the sinkHandle from 
DataBlockManager ?
-      logger.error("Sink handle {} failed due to {}", sinkHandle, t);
+      logger.error("Sink handle failed due to", t);
       if (onFailureCallback != null) {
         onFailureCallback.call(t);
       }
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java 
b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
index b8ff45b639..7569294351 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/Coordinator.java
@@ -113,6 +113,9 @@ public class Coordinator {
 
     QueryId globalQueryId = queryIdGenerator.createNextQueryId();
     try (SetThreadName queryName = new SetThreadName(globalQueryId.getId())) {
+      if (sql != null) {
+        LOGGER.info("start executing sql: {}", sql);
+      }
       IQueryExecution execution =
           createQueryExecution(
               statement,