Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-127924076
Why isn't rebalance implied when the 2 operators don't have the same
parallelism and partitioning is not defined? If you don't specify the
partitioning (which defaults to forward) means that you don't specifically
care, in this case implied rebalance is the most natural thing.
It's arguable that if the user specifically says forward then we give an
error but otherwise I this this just hurts the developers.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
