This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 2d2d92e  [FLINK-24046][state] Refactor the EmbeddedRocksDBStateBackend 
configuration logic
     add 3761bbf  [FLINK-24980] Introduce numBytesProduced counter into 
ResultPartition to record the size of result partition.

No new revisions were added by this update.

Summary of changes:
 .../flink/runtime/executiongraph/IOMetrics.java    | 23 ++++++++++++-
 .../partition/BufferWritingResultPartition.java    |  8 +++--
 .../io/network/partition/ResultPartition.java      | 10 ++++++
 .../partition/SortMergeResultPartition.java        |  1 +
 .../runtime/metrics/groups/TaskIOMetricGroup.java  | 18 +++++++++-
 .../io/network/partition/ResultPartitionTest.java  | 38 ++++++++++++++++++++++
 .../partition/SortMergeResultPartitionTest.java    | 33 +++++++++++++++++++
 .../metrics/groups/TaskIOMetricGroupTest.java      | 27 +++++++++++++++
 8 files changed, 154 insertions(+), 4 deletions(-)

Reply via email to