[jira] [Updated] (FLINK-24382) RecordsOut metric for sinks is inaccurate

["ASF GitHub Bot (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-24382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

ASF GitHub Bot updated FLINK-24382:
-----------------------------------
    Labels: pull-request-available  (was: )

> RecordsOut metric for sinks is inaccurate
> -----------------------------------------
>
>                 Key: FLINK-24382
>                 URL: https://issues.apache.org/jira/browse/FLINK-24382
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Common, Runtime / Metrics
>    Affects Versions: 1.14.0, 1.15.0
>            Reporter: Fabian Paul
>            Priority: Major
>              Labels: pull-request-available
>
> Currently, the metric is computed on the operator level and it is assumed that every record flowing into the sink also generates one outgoing record.
> This is often not reasonable because the sinks can transform incoming records into multiple outgoing records, thus the metric should be implemented by the sink implementors and not be reasoned by the framework.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)