This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch PrintSQL in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 005a618c7fe058a7d6b64a9718b16e5c24dd24e8 Author: JackieTien97 <[email protected]> AuthorDate: Fri Jun 17 09:52:01 2022 +0800 Print sql and corresponding QueryId --- .../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,
