Hi Mailing list, using a RichMapPartitionFunction i can access the total number m of this mapper utilized in my job with int m = getRuntimeContext().getNumberOfParallelSubtasks();
I think that would be - in general - the total number of CPU Cores used by Apache Flink among the cluster. Is there a way to access the number of the following reducer? In general i would assume that the number of the following reducers depends on the number of groups generated by the groupBy() transformation. So the number of the reducer r would be 1 <= r <= m. My Job: DataSet<?> output = input .mapPartition(new MR_GPMRS_Mapper()) .groupBy(0) .reduceGroup(new MR_GPMRS_Reducer()); Thank you in advance Robert