This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2c3f8f6 [FLINK-23233][runtime] Ensure checkpoints confirmed after all
the failed events processed for OepratorCoordinator
add 331ae2c [FLINK-22545][coordination] Fix check during creation of
Source Coordinator thread.
No new revisions were added by this update.
Summary of changes:
.../coordinator/SourceCoordinatorProvider.java | 33 +++++++++++++++++-----
1 file changed, 26 insertions(+), 7 deletions(-)
