You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2021/09/21 08:34:56 UTC
[flink] branch release-1.14 updated (30d7200 -> 36c1b5b)
This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 30d7200 [release] Create 1.14 release-notes
add 36c1b5b [FLINK-24303][coordination] Failure when creating a source enumerator lead to full failover, not JobManager failure.
No new revisions were added by this update.
Summary of changes:
.../source/reader/CoordinatedSourceITCase.java | 164 +++++++++++++++++++++
.../source/coordinator/SourceCoordinator.java | 20 ++-
.../source/coordinator/SourceCoordinatorTest.java | 20 +++
3 files changed, 201 insertions(+), 3 deletions(-)