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 4cc33f97d13 [FLINK-28559][python] Support DataStream
PythonKeyedProcessOperator in Thread Mode
add f88489a6af4 [FLINK-28519][network] Fix the bug that
SortMergeResultPartitionReadScheduler may not read data sequentially
No new revisions were added by this update.
Summary of changes:
.../network/partition/PartitionedFileReader.java | 4 +-
.../SortMergeResultPartitionReadScheduler.java | 123 ++++++++++++---------
.../SortMergeResultPartitionReadSchedulerTest.java | 25 ++---
3 files changed, 82 insertions(+), 70 deletions(-)
