This is an automated email from the ASF dual-hosted git repository.
guoweijie pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 6fd3b9b3384 [FLINK-31351][sql-gateway] Don't stop the stuck thread by
force
add 772429f0a9c [hotfix][test] Remove meaningless reader in
SortMergeResultPartitionReadSchedulerTest#testRequestTimeoutIsRefreshedAndSuccess.
add 45c275832ae [hotfix][runtime] IO Scheduler should handle un-expected
exceptions.
add 860ce4f57b2 [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 | 36 ++++++++++++-----
.../partition/hybrid/HsFileDataManager.java | 47 +++++++++++++---------
.../SortMergeResultPartitionReadSchedulerTest.java | 22 ++++++----
.../partition/hybrid/HsFileDataManagerTest.java | 17 +++++---
.../partition/hybrid/HsResultPartitionTest.java | 16 +++++++-
5 files changed, 94 insertions(+), 44 deletions(-)