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(-)

Reply via email to