flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Aljoscha Krettek (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-2335) Rework iteration construction in StreamGraph
Date Wed, 15 Jul 2015 16:02:04 GMT

     [ https://issues.apache.org/jira/browse/FLINK-2335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel

Aljoscha Krettek resolved FLINK-2335.
    Resolution: Fixed

> 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

View raw message