This is an automated email from the ASF dual-hosted git repository.
dmvk pushed a change to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git
from 2edc003004d [FLINK-31764][runtime] Get rid of
numberOfRequestedOverdraftMemorySegments in LocalBufferPool.
new f4ab996fedd [FLINK-32010][kubernetes] Remove an unused parameter from
KubernetesLeaderRetrievalDriver.
new d4e885b2df8 [FLINK-32010][kubernetes] Rename
KubernetesUtils#checkConfigMaps to KubernetesUtils#getOnlyConfigMap to provide
more clarity.
new 9ffbafde339 [FLINK-32010][runtime] Leader election/retrieval drivers
should properly extend AutoCloseable instead of having their own close method
with the same signature.
new 2799038b964 [FLINK-32010][kubernetes] Properly handle
KubernetesLeaderRetrievalDriver.ConfigMapCallbackHandlerImpl#onAdded events in
case the leader is already known.
The 4 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:
.../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(-)
