This is an automated email from the ASF dual-hosted git repository.
yingjie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from d54fe51 [FLINK-25860][network] Move read buffer allocation and output
file creation to setup method for sort-shuffle result partition to avoid
blocking the main thread
add b562070 [FLINK-25653][network] Move buffer recycle in
SortMergeSubpartitionReader out of lock to avoid deadlock
No new revisions were added by this update.
Summary of changes:
.../partition/SortMergeSubpartitionReader.java | 36 +++++++++------
.../SortMergeResultPartitionReadSchedulerTest.java | 52 +++++++++++++++++-----
2 files changed, 64 insertions(+), 24 deletions(-)