[jira] [Created] (FLINK-3213) Union of two streams with different parallelism should adjust parallelism automatically

[Shang Yuanchun (Jira)]

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)