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)
