actually, how about the following idea that should make things a bit simpler / improve the abstraction: - only differentiate between self-flushing channels (periodically, after registration) and channels that require manual flushing (instead of remove vs. local) - have `PipelinedSubpartition#registerPeriodicFlush()` return whether registering for "self-flush" worked or not - have `PipelinedSubpartition#registerPeriodicFlush()` dealing with the local vs. non-local nature of the channel - only have `ResultSubpartition[] subpartitions` and `ArrayList<ResultSubpartition> manuallyFlushedSubpartitions` members
[ Full content available at: https://github.com/apache/flink/pull/6698 ] This message was relayed via gitbox.apache.org for [email protected]
