You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2023/04/04 05:01:46 UTC
[iotdb] branch FIDig updated: delete debug
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 <ja...@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,