Hi All Is there anyway in Flink to send a process to a reducer?
If I do "test.groupby(1).reduceGroup", each group is processed on one reducer? And if the number of groups is more than the number of task slots we have, does Flink distribute the process evenly? I mean if we have for example groups of size 10, 5, 5 and we have two task slots, is the process distributed in this way?
task slot1: group of size 10 task slot2: two groups of size 5 Best, Alieh
