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 0157aa3 [FLINK-25341][table-planner] Add StructuredToStringCastRule
add 3e206f0 [FLINK-24954][network] Refresh read buffer request timeout on
buffer recycling/requesting for sort-shuffle
add b8d1a48 [hotfix] Fix typing errors for
SortMergeResultPartitionReadScheduler#createSubpartitionReader
No new revisions were added by this update.
Summary of changes:
.../io/disk/BatchShuffleReadBufferPool.java | 12 +++
.../partition/SortMergeResultPartition.java | 2 +-
.../SortMergeResultPartitionReadScheduler.java | 40 +++++--
.../io/disk/BatchShuffleReadBufferPoolTest.java | 28 +++++
.../SortMergeResultPartitionReadSchedulerTest.java | 119 +++++++++++++++++++--
5 files changed, 184 insertions(+), 17 deletions(-)
