This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b19a515 [FLINK-23476][build] Remove unused dependency
add 9c7e300 [FLINK-22054][k8s] Using a shared watcher for ConfigMap
watching
add dfb4c00 [FLINK-22054][dist] Suppress the verbose log in kubernetes
informer
No new revisions were added by this update.
Summary of changes:
.../resource-providers/native_kubernetes.md | 3 +-
.../resource-providers/native_kubernetes.md | 3 +-
.../main/flink-bin/conf/log4j-console.properties | 4 +
.../main/flink-bin/conf/log4j-session.properties | 4 +
.../src/main/flink-bin/conf/log4j.properties | 4 +
.../src/main/flink-bin/conf/logback-console.xml | 3 +
.../src/main/flink-bin/conf/logback-session.xml | 6 +
flink-dist/src/main/flink-bin/conf/logback.xml | 6 +
.../test-scripts/test_kubernetes_itcases.sh | 1 +
.../highavailability/KubernetesHaServices.java | 26 +-
.../KubernetesLeaderElectionDriver.java | 46 +--
.../KubernetesLeaderElectionDriverFactory.java | 19 +-
.../KubernetesLeaderRetrievalDriver.java | 46 +--
.../KubernetesLeaderRetrievalDriverFactory.java | 20 +-
.../kubeclient/Fabric8FlinkKubeClient.java | 18 +-
.../kubernetes/kubeclient/FlinkKubeClient.java | 19 +-
.../KubernetesConfigMapSharedWatcher.java | 9 +-
.../kubeclient/KubernetesSharedWatcher.java | 55 ++++
...java => KubernetesConfigMapSharedInformer.java} | 21 +-
.../resources/KubernetesConfigMapWatcher.java | 69 -----
.../resources/KubernetesSharedInformer.java | 281 ++++++++++++++++++
.../KubernetesHighAvailabilityTestBase.java | 66 +++--
...KubernetesLeaderElectionAndRetrievalITCase.java | 37 ++-
.../KubernetesLeaderElectionDriverTest.java | 34 ---
.../KubernetesLeaderRetrievalDriverTest.java | 34 ---
.../kubeclient/Fabric8FlinkKubeClientTest.java | 24 --
.../kubeclient/TestingFlinkKubeClient.java | 91 ++++--
.../resources/KubernetesSharedInformerITCase.java | 322 +++++++++++++++++++++
28 files changed, 955 insertions(+), 316 deletions(-)
copy
flink-connectors/flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/fakedb/driver/FakeConnection1.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/KubernetesConfigMapSharedWatcher.java
(73%)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/KubernetesSharedWatcher.java
copy
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/{KubernetesException.java
=> KubernetesConfigMapSharedInformer.java} (53%)
delete mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesConfigMapWatcher.java
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesSharedInformer.java
create mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/resources/KubernetesSharedInformerITCase.java
