You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2022/02/07 06:40:11 UTC
[flink] branch master updated (919dca5 -> 1ae09ae)

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