You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Arvid Heise (Jira)" <ji...@apache.org> on 2021/10/06 08:34:00 UTC

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

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

Arvid Heise commented on FLINK-24382:
-------------------------------------

Merged into master as 9595767047259087820dca5fa914dd1650656805.

> 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)