zhijiangW commented on a change in pull request #10083:
[FLINK-14472][runtime]Implement back-pressure monitor with non-blocking outputs.
URL: https://github.com/apache/flink/pull/10083#discussion_r342971770
##########
File path:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/legacy/backpressure/BackPressureStats.java
##########
@@ -89,28 +88,28 @@ public long getStartTime() {
}
/**
- * Returns the time stamp, when all stack traces were collected at the
- * JobManager.
+ * Returns the time stamp, when all back pressure stats were collected
at
+ * the JobManager.
*
- * @return Time stamp, when all stack traces were collected at the
+ * @return Time stamp, when all back pressure stats were collected at
the
* JobManager
*/
public long getEndTime() {
return endTime;
}
/**
- * Returns the a map of stack traces by execution ID.
+ * Returns the a map of back pressure ratio by execution ID.
*
- * @return Map of stack traces by execution ID
+ * @return Map of back pressure ratio by execution ID
*/
- public Map<ExecutionAttemptID, List<StackTraceElement[]>>
getStackTraces() {
- return stackTracesByTask;
+ public Map<ExecutionAttemptID, Double> getBackPressureRatioByTask() {
+ return backPressureRatioByTask;
}
@Override
public String toString() {
- return "StackTraceSample{" +
+ return "TaskBackPressureStats{" +
Review comment:
TaskBackPressureStats -> BackPressureStats
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
