This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ece5fad353a [FLINK-33071][metrics,checkpointing] Log a json dump of
checkpoint statistics when checkpoint completes or fails
add 9036cc52c28 [hotfix][network] Optimize the backlog calculation logic
in Hybrid Shuffle
add 37a9ce150f2 [hotfix][network] Fix the bug of triggering disk writing
in Hybrid Shuffle
No new revisions were added by this update.
Summary of changes:
.../hybrid/tiered/netty/NettyPayloadManager.java | 52 +++++++++++++++++++---
.../netty/TieredStorageResultSubpartitionView.java | 8 ++--
.../storage/TieredStorageMemoryManagerImpl.java | 17 ++++---
.../tiered/netty/NettyConnectionWriterTest.java | 41 +++++++++++++++++
.../TieredStorageResultSubpartitionViewTest.java | 27 ++++++-----
5 files changed, 115 insertions(+), 30 deletions(-)