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 919dca5 [FLINK-25953][runtime] Reorganizes dispatcher cleanup related
tests
add 1ae09ae [FLINK-20830][k8s] Add type of Headless_Cluster_IP for
external rest service
No new revisions were added by this update.
Summary of changes:
.../generated/kubernetes_config_configuration.html | 2 +-
.../kubernetes/KubernetesClusterDescriptor.java | 7 +-
.../configuration/KubernetesConfigOptions.java | 27 +++++-
.../kubeclient/Fabric8FlinkKubeClient.java | 5 +-
.../decorators/ExternalServiceDecorator.java | 33 ++------
.../decorators/InternalServiceDecorator.java | 24 +-----
.../kubeclient/services/ClusterIPService.java | 28 +++----
.../services/HeadlessClusterIPService.java | 68 ++++++++++++++++
.../kubeclient/services/LoadBalancerService.java | 28 +++----
.../kubeclient/services/NodePortService.java | 30 +++----
.../kubeclient/services/ServiceType.java | 95 ++++++++++++++++++++++
.../apache/flink/kubernetes/utils/Constants.java | 2 -
.../flink/kubernetes/KubernetesClientTestBase.java | 32 +++++++-
.../decorators/ExternalServiceDecoratorTest.java | 17 ++++
.../factory/KubernetesJobManagerFactoryTest.java | 3 +-
.../kubeclient/services/ServiceTypeTest.java | 47 +++++++++++
16 files changed, 335 insertions(+), 113 deletions(-)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/NoOpFileChannelManager.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/services/ClusterIPService.java
(57%)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/services/HeadlessClusterIPService.java
copy
flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/NoOpFileChannelManager.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/services/LoadBalancerService.java
(57%)
copy
flink-runtime/src/test/java/org/apache/flink/runtime/io/disk/NoOpFileChannelManager.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/services/NodePortService.java
(56%)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/kubeclient/services/ServiceType.java
create mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/services/ServiceTypeTest.java
