flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fridtjof Sander <fsan...@mailbox.tu-berlin.de>
Subject DataExchangeMode.BATCH in iterations
Date Mon, 01 Feb 2016 10:47:41 GMT
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

Mime
View raw message