GitHub user GJL opened a pull request: https://github.com/apache/flink/pull/5397
[FLINK-7856][flip6] WIP WIP PR is based on #4893 @tillrohrmann You can merge this pull request into a Git repository by running: $ git pull https://github.com/GJL/flink FLINK-7856-3 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/5397.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #5397 ---- commit bea6bf16b2cac1a8da1f3d28432798965b64cea9 Author: zjureel <zjureel@...> Date: 2017-11-15T05:55:28Z [FLINK-7856][flip6] Port JobVertexBackPressureHandler to REST endpoint commit 968f0dfe8a3c6832b0e6a83c5c61eaa1fd886c1b Author: gyao <gary@...> Date: 2018-01-31T19:01:24Z [hotfix][tests] Add Javadocs to JobMasterTest Add Javadocs to JobMasterTest. Remove debug print. commit 6140fa6f460491bbe0eaf19d15b8a2f5d81622a0 Author: gyao <gary@...> Date: 2018-01-31T19:02:59Z [FLINK-7856][flip6] Implement JobVertexBackPressureHandler commit 4625a637fa0a17a0ea0a3a48952d562a29fa5c06 Author: gyao <gary@...> Date: 2018-01-31T19:06:09Z [hotfix] Log swallowed exception in JobMaster ---- ---