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

Posted to dev@flink.apache.org by "Fabian Paul (Jira)" <ji...@apache.org> on 2021/09/27 06:58:00 UTC

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

Fabian Paul created FLINK-24382:
-----------------------------------

             Summary: 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


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)