This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from dd3e60a4b1e [FLINK-34132][runtime] Correct the error message and doc
that AdaptiveBatch only supports all edges being BLOCKING or
HYBRID_FULL/HYBRID_SELECTIVE.
new 4a50d372ce5 [hotfix][test] Moves ConfigMap lifecycle management into
@BeforeEach/@AfterEach methods
new de6b3974921 [hotfix][test] Makes
ManuallyTriggeredScheduledExecutorService#execute rely on a BlockingQueue
new 8ff011fa3f6 [hotfix][test] Refactors TestingLeaderCallbackHandler to
allow async calls
new 927972ff4ad [FLINK-34007][k8s] fabric8io LeaderElector is created with
every new #run() call
new 95417a4857e [FLINK-34007][k8s] Upgrade k8s client to v6.9.2 to cover
client issue #5464
The 5 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:
flink-kubernetes/pom.xml | 2 +-
.../kubeclient/FlinkKubeClientFactory.java | 35 ++---
.../resources/KubernetesLeaderElector.java | 68 ++++++++--
.../src/main/resources/META-INF/NOTICE | 50 +++----
.../flink/kubernetes/KubernetesClientTestBase.java | 2 +-
.../resources/KubernetesLeaderElectorITCase.java | 143 +++++++++++++++++++--
.../resources/TestingLeaderCallbackHandler.java | 42 ++++--
.../ManuallyTriggeredScheduledExecutorService.java | 44 ++++---
8 files changed, 293 insertions(+), 93 deletions(-)
