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 babb82553c8 [FLINK-31347] Prevent
AdaptiveSchedulerClusterITCase.testAutomaticScaleUp timing out.
add a3068310ba9 [hotfix][test] Remove meaningless reader in
SortMergeResultPartitionReadSchedulerTest#testRequestTimeoutIsRefreshedAndSuccess.
add faf663a6298 [hotfix][runtime] IO Scheduler should handle un-expected
exceptions.
add 5ad2ae2c24a [FLINK-31346][runtime] IO scheduler does not throw
TimeoutException if numRequestedBuffers is greater than 0.
No new revisions were added by this update.
Summary of changes:
.../SortMergeResultPartitionReadScheduler.java | 38 ++++++++++++-----
.../partition/hybrid/HsFileDataManager.java | 47 +++++++++++++---------
.../SortMergeResultPartitionReadSchedulerTest.java | 22 ++++++----
.../partition/hybrid/HsFileDataManagerTest.java | 16 ++++++--
4 files changed, 80 insertions(+), 43 deletions(-)
