This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 0b5aa420180 [FLINK-28884] Reset needNotify to true when get a zero
backlog.
add e39fb24ecd7 [FLINK-28888] The statistics of HsResultPartition are not
updated correctly
No new revisions were added by this update.
Summary of changes:
.../partition/hybrid/HsMemoryDataManager.java | 8 ++++++
...erIndexAndChannel.java => HsOutputMetrics.java} | 23 +++++++--------
.../partition/hybrid/HsResultPartition.java | 10 +++++++
.../hybrid/HsSubpartitionMemoryDataManager.java | 13 +++++++++
.../partition/hybrid/HsMemoryDataManagerTest.java | 31 +++++++++-----------
.../partition/hybrid/HsResultPartitionTest.java | 24 ++++++++++++++++
.../HsSubpartitionMemoryDataManagerTest.java | 33 ++++++++++++++++++++--
.../partition/hybrid/HsSubpartitionViewTest.java | 2 ++
.../partition/hybrid/HybridShuffleTestUtils.java | 5 ++++
9 files changed, 118 insertions(+), 31 deletions(-)
copy
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/hybrid/{BufferIndexAndChannel.java
=> HsOutputMetrics.java} (62%)
