Piotr Nowojski created FLINK-12576:
--------------------------------------
Summary: inputQueueLength metric does not work for
LocalInputChannels
Key: FLINK-12576
URL: https://issues.apache.org/jira/browse/FLINK-12576
Project: Flink
Issue Type: Bug
Components: Runtime / Metrics
Affects Versions: 1.8.0, 1.7.2, 1.6.4
Reporter: Piotr Nowojski
Currently {{inputQueueLength}} ignores LocalInputChannels
({{SingleInputGate#getNumberOfQueuedBuffers}}). This can can cause mistakes
when looking for causes of back pressure (If task is back pressuring whole
Flink job, but there is a data skew and only local input channels are being
used).
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
