This is an automated email from the ASF dual-hosted git repository.
dmvk pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 9e08f205968 Revert "[FLINK-31984][fs][checkpoint] Savepoint should be
relocatable if entropy injection is not effective"
add 9d0d926fa16 [FLINK-32010][kubernetes] Remove an unused parameter from
KubernetesLeaderRetrievalDriver.
add 57c976468b0 [FLINK-32010][kubernetes] Rename
KubernetesUtils#checkConfigMaps to KubernetesUtils#getOnlyConfigMap to provide
more clarity.
add af734bf1bc4 [FLINK-32010][runtime] Leader election/retrieval drivers
should properly extend AutoCloseable instead of having their own close method
with the same signature.
add 6aa84630a39 [FLINK-32010][kubernetes] Properly handle
KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in
case the leader is already known.
No new revisions were added by this update.
Summary of changes:
.../KubernetesLeaderElectionDriver.java | 8 +-
.../KubernetesLeaderRetrievalDriver.java | 19 ++--
.../KubernetesLeaderRetrievalDriverFactory.java | 6 --
...netesMultipleComponentLeaderElectionDriver.java | 8 +-
...tipleComponentLeaderRetrievalDriverFactory.java | 1 -
.../flink/kubernetes/utils/KubernetesUtils.java | 12 ++-
.../KubernetesHighAvailabilityTestBase.java | 1 -
...KubernetesLeaderElectionAndRetrievalITCase.java | 103 +++++++++++++--------
.../leaderelection/LeaderElectionDriver.java | 5 +-
.../leaderretrieval/LeaderRetrievalDriver.java | 6 +-
.../TestingLeaderElectionEventHandler.java | 3 +-
11 files changed, 96 insertions(+), 76 deletions(-)
