Hey guys, Is there any way to monitor the backpressure in the Flink job? I find it hard to debug slow operators because of the backpressure mechanism so it would be good to get some info out of the network layer on what exactly caused the backpressure.
For example: task1 -> task2 -> task3 -> task4 I want to figure out whether task 2 or task 3 is slow. Any ideas? Thanks, Gyula
