Github user gyfora commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-128404999
It would be good to get some feedback from the others as well, but in
general my arguments are the following:
1. Getting exceptions after non-parallel sources just because you didn't
rebalance (or in any other case), is very confusing for the user and seems
unintuitive. Therefore I vote for fixing the current behaviour and keeping
rebalance implied.
2. There is probably a good reason why a user implements an operator (maybe
some outside world communication), so not executing it (for instance no sink
attached) will lead to incorrect behaviour. Also we cannot force someone to
always use a sink in this case as they might need some special behaviour
implemented by some other operator.
---
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.
---
