[FLINK-31752] SourceOperatorStreamTask increments numRecordsOut twice

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.17.0
• Fix Version/s: 1.18.0, 1.17.1
• Component/s: Runtime / Metrics
• Labels: pull-request-available
• Assignee: Yunfeng Zhou
• Reporter: !huwh
• Created: 07/Apr/23 08:00
• Updated: 13/Dec/23 08:46
• Resolved: 23/Apr/23 06:26

Description

The counter of numRecordsOut was introduce to ChainingOutput to reduce the function call stack depth in
https://issues.apache.org/jira/browse/FLINK-30536

But SourceOperatorStreamTask.AsyncDataOutputToOutput increments the counter of numRecordsOut too. This results in the source operator's numRecordsOut are doubled.

We should delete the numRecordsOut.inc in SourceOperatorStreamTask.AsyncDataOutputToOutput.

xtsonglindong Could you please take a look at this.

Issue Links

• links to: GitHub Pull Request #22449
• links to: GitHub Pull Request #22462