This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch release-1.18
in repository https://gitbox.apache.org/repos/asf/flink.git
from d69393678ef [FLINK-34422][test] BatchTestBase uses MiniClusterExtension
new e5d488c9e5b [hotfix][test] Moves ConfigMap lifecycle management into
@BeforeEach/@AfterEach methods
new 6441f5845f7 [hotfix][test] Makes
ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue
new 38690d06e00 [hotfix][test] Refactors TestingLeaderCallbackHandler to
allow async calls
new 0afa89d2840 [hotfix][core] Makes ExecutorUtils#gracefulShutdown return
any outstanding tasks
new 87560b7cedd [FLINK-34333][k8s] fabric8io LeaderElector is created with
every new #run() call (cherry-picked from FLINK-34007)
new 35c560312ef [FLINK-34333][k8s] Upgrade k8s client to v6.9.2 to cover
client issue #5464 (cherry-picked from FLINK-34007)
The 6 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:
.../java/org/apache/flink/util/ExecutorUtils.java | 14 ++-
flink-kubernetes/pom.xml | 2 +-
.../kubeclient/FlinkKubeClientFactory.java | 35 +++---
.../resources/KubernetesLeaderElector.java | 77 ++++++++++--
.../src/main/resources/META-INF/NOTICE | 52 ++++----
.../flink/kubernetes/KubernetesClientTestBase.java | 2 +-
.../resources/KubernetesLeaderElectorITCase.java | 132 ++++++++++++++++++++-
.../resources/TestingLeaderCallbackHandler.java | 42 +++++--
.../ManuallyTriggeredScheduledExecutorService.java | 44 ++++---
9 files changed, 311 insertions(+), 89 deletions(-)
