[ 
https://issues.apache.org/jira/browse/FLINK-24657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17719774#comment-17719774
 ] 

Weijie Guo commented on FLINK-24657:
------------------------------------

Thanks [~pnowojski] for providing the discussion reference. 

It makes sense to convert input metrics to ignore local channels everywhere. 
For {{inputQueueLength}}, including the data in the {{SubpartitionView}} is 
indeed a bit strange, especially since it has already been included on the 
output side. But let's carefully consider whether this change is necessary, as 
many users may have already done somethings based on these metrics.

> Add metric of the total real size of input/output buffers queue 
> ----------------------------------------------------------------
>
>                 Key: FLINK-24657
>                 URL: https://issues.apache.org/jira/browse/FLINK-24657
>             Project: Flink
>          Issue Type: Improvement
>          Components: Runtime / Metrics
>    Affects Versions: 1.14.0
>            Reporter: Anton Kalashnikov
>            Assignee: Anton Kalashnikov
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0
>
>
> Right now we have the metric of the length of input/output buffers queue but 
> since buffer debloater has been introduced this metric is not always helpful 
> because the real size of each buffer can be different. So it is an idea to 
> add a new metric that shows the total size of buffers in the queue.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to