[GitHub] flink pull request #5397: [FLINK-7856][flip6] WIP JobVertexBackPressureHandl...

[GJL]

Github user GJL commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5397#discussion_r165835486
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java 
---
    @@ -313,6 +325,13 @@ public JobMaster(
                        .orElse(FutureUtils.completedExceptionally(new 
JobMasterException("The JobMaster has not been started with a REST 
endpoint.")));
     
                this.metricQueryServicePath = metricQueryServicePath;
    +           this.stackTraceSampleCoordinator = new 
StackTraceSampleCoordinator(rpcService.getExecutor(), 
rpcTimeout.toMilliseconds());
    +           this.backPressureStatsTracker = new BackPressureStatsTracker(
    --- End diff --
    
    done


---