flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Stephan Ewen (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically
Date Sun, 10 Jan 2016 19:07:39 GMT
Stephan Ewen created FLINK-3213:
-----------------------------------

             Summary: Union of two streams with different parallelism should adjust parallelism
automatically
                 Key: FLINK-3213
                 URL: https://issues.apache.org/jira/browse/FLINK-3213
             Project: Flink
          Issue Type: Improvement
          Components: Streaming
    Affects Versions: 0.10.1
            Reporter: Stephan Ewen
             Fix For: 1.0.0


Currently, attempting to take the union of two streams with different parallelism does not
work, the operation is rejected. One needs to manually rebalance() to adjust the parallelism.

The rebalance() should be inserted automatically.

Here is an example that shows how to reproduce this: https://gist.github.com/smarthi/f49f387008f333c0c434



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

Mime
View raw message