You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/05/31 13:12:29 UTC
[flink] 02/02: [hotfix][network] Remove legacy private
TaskEventDispatcher from NetworkEnvironment
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit d1da5e153f3583eb57aca90282d8f21910c7b0e1
Author: Zhijiang <wa...@aliyun.com>
AuthorDate: Wed May 29 10:15:19 2019 +0800
[hotfix][network] Remove legacy private TaskEventDispatcher from NetworkEnvironment
---
.../java/org/apache/flink/runtime/io/network/NetworkEnvironment.java | 5 -----
1 file changed, 5 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java
index 561909c..b90e903 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/NetworkEnvironment.java
@@ -94,8 +94,6 @@ public class NetworkEnvironment {
private final Map<InputGateID, SingleInputGate> inputGatesById;
- private final TaskEventPublisher taskEventPublisher;
-
private final ResultPartitionFactory resultPartitionFactory;
private final SingleInputGateFactory singleInputGateFactory;
@@ -107,7 +105,6 @@ public class NetworkEnvironment {
NetworkBufferPool networkBufferPool,
ConnectionManager connectionManager,
ResultPartitionManager resultPartitionManager,
- TaskEventPublisher taskEventPublisher,
ResultPartitionFactory resultPartitionFactory,
SingleInputGateFactory singleInputGateFactory) {
this.config = config;
@@ -115,7 +112,6 @@ public class NetworkEnvironment {
this.connectionManager = connectionManager;
this.resultPartitionManager = resultPartitionManager;
this.inputGatesById = new ConcurrentHashMap<>();
- this.taskEventPublisher = taskEventPublisher;
this.resultPartitionFactory = resultPartitionFactory;
this.singleInputGateFactory = singleInputGateFactory;
this.isShutdown = false;
@@ -164,7 +160,6 @@ public class NetworkEnvironment {
networkBufferPool,
connectionManager,
resultPartitionManager,
- taskEventPublisher,
resultPartitionFactory,
singleInputGateFactory);
}