Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5397#discussion_r165291604
--- 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 --
The `BackPressureStatsTracker` and the `StackTraceSampleCoordinator` could
go into the `JobManagerServices`. That way, we would have a way to pass it into
the `JobMaster`.
---
