Hi Urs,
Yes, the returned “index” from the custom partitioner refers to the parallel
subtask index.
I agree that the mismatching terminology used could be slightly misleading.
Could you open a JIRA to improve the Javadoc for that? Thanks!
Cheers,
Gordon
On 27 June 2017 at 10:40:47 PM, Urs Sch
Hi,
if I use DataStream::partitionCustom, will the partition number that my
custom Partitioner returns always be equal to getIndexOfThisSubtask
in the following operator?
A test case with different parallelisms seems to suggest this is true,
but the Javadoc seems ambiguous to me since the Partiti
