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 <
[hidden email]> 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