You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/02/28 16:17:48 UTC
[2/7] flink git commit: [hotfix][runtime] Remove duplicated check
[hotfix][runtime] Remove duplicated check
(cherry picked from commit 42f71f6)
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6b7a4480
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6b7a4480
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6b7a4480
Branch: refs/heads/release-1.5
Commit: 6b7a4480ef8610df3ff21eb2811b9a0a3c58c912
Parents: bb459cc
Author: Piotr Nowojski <pi...@gmail.com>
Authored: Fri Feb 23 12:11:14 2018 +0100
Committer: Stefan Richter <s....@data-artisans.com>
Committed: Wed Feb 28 17:16:51 2018 +0100
----------------------------------------------------------------------
.../runtime/io/network/partition/consumer/UnionInputGate.java | 7 -------
1 file changed, 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6b7a4480/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
index 5a547ea..481599c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/UnionInputGate.java
@@ -177,13 +177,6 @@ public class UnionInputGate implements InputGate, InputGateListener {
}
}
- if (bufferOrEvent.moreAvailable()) {
- // this buffer or event was now removed from the non-empty gates queue
- // we re-add it in case it has more data, because in that case no "non-empty" notification
- // will come for that gate
- queueInputGate(inputGate);
- }
-
// Set the channel index to identify the input channel (across all unioned input gates)
final int channelIndexOffset = inputGateToIndexOffsetMap.get(inputGate);