Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/988#issuecomment-128405914
+1 for rebalancing automatically between operators of different DOP. The
batch API does the same. But it should really be "rebalance", not a form of
forward that typically creates skew.
I am somewhat indifferent to the sink-or-no-sink question. The batch API
requires sinks strictly, and it makes total sense there. For streaming, it may
be different.
If we require sinks, we should have a simple function `sink()` or so, which
marks the operation as sink, so we don't force people to implement a
*discarding sink* or so unnecessarily.
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
