flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alieh <sae...@informatik.uni-leipzig.de>
Subject Flink groupBy
Date Wed, 19 Apr 2017 12:42:40 GMT
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



View raw message