[
https://issues.apache.org/jira/browse/FLINK-36779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36779:
-----------------------------------
Labels: pull-request-available (was: )
> topn.cache.size metric is incorrect and non-changing during the time
> ---------------------------------------------------------------------
>
> Key: FLINK-36779
> URL: https://issues.apache.org/jira/browse/FLINK-36779
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Runtime
> Reporter: Roman Boyko
> Priority: Minor
> Labels: pull-request-available
>
> AbstractTopNFunction#registerMetric uses 'long heapSize' to create the metric
> 'topn.cache.size' and set its value. But the heapSize is passed by value so
> it remains the same during the operator life.
> It's resulting to non-changing metric value for UpdatableTopNFunction and 0
> metric value for AppendOnlyTopNFunction, FastTop1Function and
> AppendOnlyFirstNFunction.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)