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 bb01c3070ea [FLINK-34115][table-planner] Fix TableAggregateITCase
unstable test
new 4aa4507507b [hotfix][runtime] Fix resource releasing and recovery
logic in shuffle
new 71c9760322e [FLINK-34225][runtime] Fix the race condition in
UnionResultSubpartitionView
new 973190e8ca5 [FLINK-34233][runtime] Avoid enqueuing input channel
before subpartitions initialized
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../io/network/partition/ResultPartition.java | 15 ++--
.../partition/UnionResultSubpartitionView.java | 84 ++++++++++++++++++----
.../partition/consumer/SingleInputGate.java | 7 +-
.../tier/remote/RemoteTierConsumerAgent.java | 39 +++-------
.../io/network/partition/ResultPartitionTest.java | 44 ++++++++++++
.../partition/UnionResultSubpartitionViewTest.java | 51 ++++++++++++-
6 files changed, 189 insertions(+), 51 deletions(-)
