[FLINK-12674] BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers is not implemented

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.9.0, 1.10.2, 1.11.2
• Component/s: Runtime / Metrics, Runtime / Network
• Labels: auto-deprioritized-major stale-minor
• Assignee: Unassigned
• Reporter: Piotr Nowojski
• Created: 29/May/19 13:40
• Updated: 16/Nov/21 15:20

Description

Currently BoundedBlockingSubpartition#unsynchronizedGetNumberOfQueuedBuffers returns always 0, which affects metrics and is a regression compared to the old SpillableSubpartition. Is there a way to implement it?

 

Note that before taking this ticket, make sure what's the current status of the issue reported https://issues.apache.org/jira/browse/FLINK-12070?focusedCommentId=16849615&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-16849615 which might affect the final implementation.

Issue Links

• is caused by: FLINK-12070 Make blocking result partitions consumable multiple times
• is related to: FLINK-12576 inputQueueLength metric does not work for LocalInputChannels