flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Gyula Fora (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-2328) Applying more than one transformation on an IterativeDataStream fails
Date Wed, 08 Jul 2015 14:02:04 GMT
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)

Mime
View raw message