Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/4893
@tillrohrmann Thank you for you suggestions, and I think move these things
to the `JobMaster` would be good. I think this issue could be fixed as follows:
1. Add `CompletableFuture<JobVertexBackPressureInfo>
requestVertexBackPressure(JobID jobId, JobVertexID vertexID, @RpcTimeout Time
timeout);` method in `RestfulGateway` and `JobMasterGateway`.
2. Add `BackPressureStatsTracker` to `JobMaster,` and return
`JobVertexBackPressureInfo` in method `requestVertexBackPressure`
3. Use `LegacyRestHandlerAdapter` in `DispatcherRestEndpoint` for
`JobVertexBackPressureHandler`
What do you think? thanks
---
