You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Gyula Fora (JIRA)" <ji...@apache.org> on 2015/07/09 12:51:04 UTC

[jira] [Created] (FLINK-2335) Rework iteration construction in StreamGraph

Gyula Fora created FLINK-2335:
---------------------------------

             Summary: Rework iteration construction in StreamGraph
                 Key: FLINK-2335
                 URL: https://issues.apache.org/jira/browse/FLINK-2335
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
            Reporter: Gyula Fora
            Assignee: Gyula Fora


Currently the nodes representing the extra sinks and sources are incrementally added to the streamgraph when the user creates the iterative parts of the program.

This makes it difficult to enforce different partitioning schemes on the feedback edges and also makes it virtually impossible to handle more iteration heads with different parallelism.

The actual nodes in the streamgraph for the iteration sinks/sources should only be created when the program is finalized  after the user calls execute and before we create the jobgraph.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)