You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by gy...@apache.org on 2015/05/22 14:41:27 UTC
flink git commit: [streaming] Minor bugfix in the BarrierBuffer input
finishing logic
Repository: flink
Updated Branches:
refs/heads/master 1aad5b759 -> 36c2026fb
[streaming] Minor bugfix in the BarrierBuffer input finishing logic
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/36c2026f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/36c2026f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/36c2026f
Branch: refs/heads/master
Commit: 36c2026fbc19ca3b6929888e784f76a8824011f4
Parents: 1aad5b7
Author: Gyula Fora <gy...@apache.org>
Authored: Fri May 22 13:50:43 2015 +0200
Committer: Gyula Fora <gy...@apache.org>
Committed: Fri May 22 14:22:25 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/36c2026f/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
index bc153f9..8f8325f 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/io/BarrierBuffer.java
@@ -233,7 +233,7 @@ public class BarrierBuffer {
LOG.debug("Publishing barrier to the vertex");
}
- if (currentSuperstep != null) {
+ if (currentSuperstep != null && !inputFinished) {
reader.publish(currentSuperstep);
}