[streaming] Fix bug with iteration sink/source syncing

fdac963d · Gyula Fora · 0cfa43d7 · fdac963d
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java ...ava/org/apache/flink/streaming/api/graph/StreamGraph.java +1 -1

未找到文件。
--- 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);