[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351663#comment-16351663
]
ASF GitHub Bot commented on FLINK-7856:
---------------------------------------
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
> Port JobVertexBackPressureHandler to REST endpoint
> --------------------------------------------------
>
> Key: FLINK-7856
> URL: https://issues.apache.org/jira/browse/FLINK-7856
> Project: Flink
> Issue Type: Sub-task
> Components: Distributed Coordination, REST, Webfrontend
> Reporter: Fang Yong
> Assignee: Gary Yao
> Priority: Major
>
> Port JobVertexBackPressureHandler to REST endpoint
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
