flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gyf...@apache.org
Subject flink git commit: [streaming] Minor bugfix in the BarrierBuffer input finishing logic
Date Fri, 22 May 2015 12:41:27 GMT
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 <gyfora@apache.org>
Authored: Fri May 22 13:50:43 2015 +0200
Committer: Gyula Fora <gyfora@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);
 		}
 


Mime
View raw message