Lijie Wang created FLINK-24980: ---------------------------------- Summary: Collect sizes of result partitions when tasks finish Key: FLINK-24980 URL: https://issues.apache.org/jira/browse/FLINK-24980 Project: Flink Issue Type: Sub-task Components: Runtime / Metrics Reporter: Lijie Wang
The adaptive batch job scheduler needs to know the size of each result partition when the task is finished. This issue will introduce the *numBytesProduced* counter and register it into {*}TaskIOMetricGroup{*}, to record the size of each result partition. -- This message was sent by Atlassian Jira (v8.20.1#820001)