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)
