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/1255

I 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

Reply via email to