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

Reply via email to