[
https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16351662#comment-16351662
]
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_r165835483
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobMaster.java
---
@@ -867,6 +889,25 @@ public void heartbeatFromResourceManager(final
ResourceID resourceID) {
}
}
+ @Override
+ public CompletableFuture<Optional<OperatorBackPressureStats>>
getOperatorBackPressureStats(
+ final JobID jobId, final JobVertexID jobVertexId) {
+ final ExecutionJobVertex jobVertex =
executionGraph.getJobVertex(jobVertexId);
+ if (jobVertex == null) {
+ return FutureUtils.completedExceptionally(new
FlinkException("JobVertexID not found " +
+ jobVertexId));
+ }
+
+ final Optional<OperatorBackPressureStats>
operatorBackPressureStats =
+
backPressureStatsTracker.getOperatorBackPressureStats(jobVertex);
+ if (!operatorBackPressureStats.isPresent() ||
+ backPressureStatsRefreshInterval <=
System.currentTimeMillis() - operatorBackPressureStats.get().getEndTimestamp())
{
+
backPressureStatsTracker.triggerStackTraceSample(jobVertex);
+ return
CompletableFuture.completedFuture(Optional.empty());
--- 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)
