This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 2ee862e48d0 [FLINK-37298] Added Pluggable Components for BatchStrategy
& BufferWrapper in AsyncSinkWriter. (#26274)
add 9d6ae161c9d [hotfix] Fix test coverage of WatermarkAlignmentITCase
add 0849018c266 [FLINK-37670][runtime] Fix watermark alignment can
deadlock job if there are no more splits to be assigned
No new revisions were added by this update.
Summary of changes:
.../operators/coordination/OperatorEvent.java | 10 ++-
.../operators/coordination/SubtaskGatewayImpl.java | 6 ++
.../source/coordinator/SourceCoordinator.java | 15 ++--
.../source/event/WatermarkAlignmentEvent.java | 9 ++
.../coordination/EventReceivingTasks.java | 9 +-
.../coordination/SubtaskGatewayImplTest.java | 25 ++++++
.../operators/coordination/TestOperatorEvent.java | 12 +++
.../api/datastream/WatermarkAlignmentITCase.java | 96 ++++++++++++++++++++--
8 files changed, 165 insertions(+), 17 deletions(-)
