Hello! I found out that the cause of the problem was the map that I have after the parallel join with parallelism 1. When I changed it to .map(new MyMapMeter).setParallelism(p) then when I increase the number of parallelism p the completion time decreases, which is reasonable. Somehow it was a bottleneck of my parallel execution plan, but I had it this way in order to measure a valid average throughput.
So, my question is the following: How can I measure the average throughput of my parallel join operation properly? Best, Max -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
