[iotdb] branch FIDig updated: delete debug

[jackietien]

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

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


The following commit(s) were added to refs/heads/FIDig by this push:
     new c9644afa92 delete debug
c9644afa92 is described below

commit c9644afa923637889719505395055616ab32c007
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Tue Apr 4 13:01:36 2023 +0800

    delete debug
---
 .../execution/exchange/MPPDataExchangeManager.java   | 20 --------------------
 1 file changed, 20 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 5b3cebbfc1..b8a6bd9dee 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
@@ -527,12 +527,6 @@ public class MPPDataExchangeManager implements 
IMPPDataExchangeManager {
       // FragmentInstanceContext
       FragmentInstanceContext instanceContext) {
 
-    LOGGER.debug(
-        "Create local sink handle to plan node {} of {} for {}",
-        remotePlanNodeId,
-        remoteFragmentInstanceId,
-        localFragmentInstanceId);
-
     SharedTsBlockQueue queue;
     Map<String, ISourceHandle> sourceHandleMap = 
sourceHandles.get(remoteFragmentInstanceId);
     LocalSourceHandle localSourceHandle =
@@ -557,7 +551,6 @@ public class MPPDataExchangeManager implements 
IMPPDataExchangeManager {
    */
   public ISinkChannel createLocalSinkChannelForPipeline(
       DriverContext driverContext, String planNodeId) {
-    LOGGER.debug("Create local sink handle for {}", 
driverContext.getDriverTaskID());
     SharedTsBlockQueue queue =
         new SharedTsBlockQueue(
             driverContext.getDriverTaskID().getFragmentInstanceId().toThrift(),
@@ -579,12 +572,6 @@ public class MPPDataExchangeManager implements 
IMPPDataExchangeManager {
       // FragmentInstanceContext
       FragmentInstanceContext instanceContext) {
 
-    LOGGER.debug(
-        "Create sink handle to plan node {} of {} for {}",
-        remotePlanNodeId,
-        remoteFragmentInstanceId,
-        localFragmentInstanceId);
-
     return new SinkChannel(
         remoteEndpoint,
         remoteFragmentInstanceId,
@@ -665,7 +652,6 @@ public class MPPDataExchangeManager implements 
IMPPDataExchangeManager {
    */
   public ISourceHandle createLocalSourceHandleForPipeline(
       SharedTsBlockQueue queue, DriverContext context) {
-    LOGGER.debug("Create local source handle for {}", 
context.getDriverTaskID());
     return new LocalSourceHandle(
         queue,
         new PipelineSourceHandleListenerImpl(context::failed),
@@ -740,12 +726,6 @@ public class MPPDataExchangeManager implements 
IMPPDataExchangeManager {
               + " exists.");
     }
 
-    LOGGER.debug(
-        "Create source handle from {} for plan node {} of {}",
-        remoteFragmentInstanceId,
-        localPlanNodeId,
-        localFragmentInstanceId);
-
     SourceHandle sourceHandle =
         new SourceHandle(
             remoteEndpoint,