Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.17.0
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.
Xintong SongDong Lin Could you please take a look at this.