Dear Flink-Devs,I recently ran into a problem where range-partitioning within iterations would be useful.
In the PR for range-partitioning it is said, this doesn't work because of some batched data-exchange mode.
https://github.com/apache/flink/pull/1255I would like to understand the issue with that, but could not find articles/blog posts/etc to read about that.
Do you have some pointers for me? Code will also work if the concept gets clear from it.
Thanks for your time! Best, Fridtjof