Hey, The JobGraph that is executed cannot have cycles (due to scheduling reasons), that's why there is no edge between the head and tail operators.
What we do instead is we add an extra source to the head and a sink to the tail (with the same parallelism), and the feedback data is passed outside of the graph using blocking queues. Cheers, Gyula MaGuoWei <maguo...@outlook.com> ezt írta (időpont: 2015. júl. 28., K, 3:39): > Hi,guysI am reading the code about streaming iteration.I find there is no > StreamEdge the StreamIterationHead and StreamIterationTail.Why? Because the > graph can't have any ring?Or any other concerns? > thanks
