Hello,

While implementing the SAMOA adapter for Flink-Streaming we stumbled upon the 
need to allow loops (or circular dependencies) in the job graph. Many 
incremental machine learning tasks define loops already  and there is no 
trivial way of getting around it. In the streaming job graph builder there is 
only a check that does not allow the user to submit graphs with loops, however, 
from what Gyula told me, if the check is removed the streaming job runs as 
expected. Is there (still) a major reason for having this check, at least in 
the streaming component? 

Paris

Reply via email to