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

["Arvid Heise (Jira)" <ji...@apache.org>]

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

Arvid Heise resolved FLINK-24382.
---------------------------------
    Fix Version/s: 1.14.1
                   1.15.0
         Assignee: Fabian Paul
       Resolution: Fixed

> 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
>            Assignee: Fabian Paul
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.15.0, 1.14.1
>
>
> 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)