[jira] [Created] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails

Shang Yuanchun (Jira)
Gyula Fora created FLINK-2328:
---------------------------------

             Summary: Applying more than one transformation on an IterativeDataStream fails
                 Key: FLINK-2328
                 URL: https://issues.apache.org/jira/browse/FLINK-2328
             Project: Flink
          Issue Type: Bug
            Reporter: Gyula Fora


Currently the user cannot apply more than one transformation on the IterativeDataStream directly.

It fails because instead of creating one iteration source and connecting it to the operators it will try to create two iteration sources which fails on the shared broker slot.

A workaround is to use a no-op mapper on the iterative stream and applying the two transformations on that.



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