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/25 16:57:44 UTC
flink git commit: [streaming] Fix bug with iteration sink/source
syncing
Repository: flink
Updated Branches:
refs/heads/master 0cfa43d79 -> fdac963d5
[streaming] Fix bug with iteration sink/source syncing
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fdac963d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fdac963d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fdac963d
Branch: refs/heads/master
Commit: fdac963d5ccdb0397cc069d701bccd6bd04eae5e
Parents: 0cfa43d
Author: Gyula Fora <gy...@apache.org>
Authored: Mon May 25 16:13:35 2015 +0200
Committer: Gyula Fora <gy...@apache.org>
Committed: Mon May 25 16:13:35 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/streaming/api/graph/StreamGraph.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/fdac963d/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
----------------------------------------------------------------------
diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
index 593b476..ffc7032 100644
--- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
+++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
@@ -196,7 +196,7 @@ public class StreamGraph extends StreamingPlan {
chaining = false;
- StreamLoop iteration = new StreamLoop(iterationID, getStreamNode(iterationHead), timeOut);
+ StreamLoop iteration = new StreamLoop(iterationID, getStreamNode(vertexID), timeOut);
streamLoops.put(iterationID, iteration);
vertexIDtoLoop.put(vertexID, iteration);