[ https://issues.apache.org/jira/browse/FLINK-31752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Weihua Hu updated FLINK-31752: ------------------------------ 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 was: 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 !image-2023-04-07-15-51-44-304.png! > SourceOperatorStreamTask increments numRecordsOut twice > ------------------------------------------------------- > > Key: FLINK-31752 > URL: https://issues.apache.org/jira/browse/FLINK-31752 > Project: Flink > Issue Type: Bug > Components: Runtime / Metrics > Affects Versions: 1.17.0 > Reporter: Weihua Hu > Priority: Major > Attachments: image-2023-04-07-15-51-44-304.png > > > 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 -- This message was sent by Atlassian Jira (v8.20.10#820010)