You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by zh...@apache.org on 2021/12/01 07:22:45 UTC
[flink] branch master updated (2d2d92e -> 3761bbf)
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(-)