[FLINK-3213] Union of two streams with different parallelism should adjust parallelism automatically

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 0.10.1
• Fix Version/s: 1.0.0
• Assignee: Suneel Marthi
• Reporter: Stephan Ewen
• Created: 10/Jan/16 19:06
• Updated: 28/Feb/19 11:14
• Resolved: 12/Jan/16 12:19

Description

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