[ https://issues.apache.org/jira/browse/FLINK-7856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16348261#comment-16348261 ]
ASF GitHub Bot commented on FLINK-7856: --------------------------------------- Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5397#discussion_r165291802 --- 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 -- Why not returning the last back-pressure result if there is an old one? > 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)