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 <gyf...@apache.org> Authored: Fri May 22 13:50:43 2015 +0200 Committer: Gyula Fora <gyf...@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); }
