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 c8dfb2a1c68 [FLINK-32430][table] Support configuring CatalogStore
using configuration
new 51b0df65886 [FLINK-32640][Network] Measure backpressure time for
legacy hybrid shuffle.
new eab99b6de82 [FLINK-32640][Network] Measure backpressure time for
tiered storage hybrid shuffle.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../partition/hybrid/HsMemoryDataManager.java | 19 +++++++++++++-
.../network/partition/hybrid/HsOutputMetrics.java | 11 +++++++-
.../partition/hybrid/HsResultPartition.java | 6 ++++-
.../tiered/shuffle/TieredResultPartition.java | 1 +
.../tiered/storage/TieredStorageMemoryManager.java | 8 ++++++
.../storage/TieredStorageMemoryManagerImpl.java | 30 ++++++++++++++++++----
.../partition/hybrid/HybridShuffleTestUtils.java | 3 ++-
.../tiered/TestingTieredStorageMemoryManager.java | 13 ++++++++++
8 files changed, 82 insertions(+), 9 deletions(-)
