-
Type:
Bug
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: 1.6.4, 1.7.2, 1.8.0, 1.9.0
-
Fix Version/s: 1.9.0
-
Component/s: Runtime / Metrics, Runtime / Network
-
Labels:
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).
- relates to
-
FLINK-12674 BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented
-
- Open
-
- links to