lining created FLINK-14712:
------------------------------
Summary: Add NetWork metric for IOMetricsInfo
Key: FLINK-14712
URL: https://issues.apache.org/jira/browse/FLINK-14712
Project: Flink
Issue Type: Bug
Components: Runtime / Metrics, Runtime / Network, Runtime / REST
Reporter: lining
Attachments: image-2019-11-12-14-30-16-130.png
h4. (1) The current monitor is heavy-weight.
* Backpressure monitoring works by repeatedly taking stack trace samples of
your running tasks.
h4. (2) It is difficult to find out which vertex is the source of
backpressure.
* User need to know current and upstream's network metric to judge current
whether is the source of backpressure. Now user has to record relevant
information.
h3. Proposed Changes
Update IOMetricsInfo add outPoolUsage, inputExclusiveBuffersUsage,
inputFloatingBuffersUsage:
public final class IOMetricsInfo { private final float outPoolUsage;
private final float inputExclusiveBuffersUsage; private final float
inputFloatingBuffersUsage;}
JobDetailsInfo.JobVertexDetailsInfo merge use Math.max.(ps: outPoolUsage is
from upstream)、
According to !image-2019-11-12-14-30-16-130.png!
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
