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 2ade17dc297 [hotfix][table][tests] Replace ExpectedException with
assertJ
new ff7d61954ca [hotfix]Remove unused variable in KubernetesEntrypointUtils
new ab3eb40d920 [Flink-26112][k8s]Refactor the FlinkKubeClient interface
to deal with service name directly
new f24dc6da252 [FLINK-26112][k8s]Port getRestEndpoint method to the
specific service type subclass
The 3 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:
.../kubernetes/KubernetesClusterDescriptor.java | 5 +-
.../KubernetesResourceManagerDriver.java | 18 ++-
.../flink/kubernetes/cli/KubernetesSessionCli.java | 4 +-
.../entrypoint/KubernetesEntrypointUtils.java | 5 -
.../kubeclient/Fabric8FlinkKubeClient.java | 146 ++-------------------
.../kubernetes/kubeclient/FlinkKubeClient.java | 15 +--
.../decorators/ExternalServiceDecorator.java | 5 +-
.../kubeclient/resources/KubernetesService.java | 6 -
.../kubeclient/services/ClusterIPService.java | 23 ++++
.../kubeclient/services/LoadBalancerService.java | 92 +++++++++++++
.../kubeclient/services/NodePortService.java | 48 +++++++
.../kubeclient/services/ServiceType.java | 49 +++++++
.../flink/kubernetes/utils/KubernetesUtils.java | 6 +
.../flink/kubernetes/KubernetesClientTestBase.java | 1 +
.../kubeclient/Fabric8FlinkKubeClientTest.java | 15 +--
.../kubeclient/TestingFlinkKubeClient.java | 8 +-
16 files changed, 257 insertions(+), 189 deletions(-)
