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 4255652 [FLINK-25715][coordination] Allow submission of failed jobs
add c7219f8 [hotfix][runtime] Extract a common method to parse rest port
from web interface URL
add 36e98b3 [FLINK-24947][k8s] Support host network for native K8s
integration
No new revisions were added by this update.
Summary of changes:
.../generated/kubernetes_config_configuration.html | 6 ++
.../kubernetes/KubernetesClusterDescriptor.java | 3 +-
.../KubernetesResourceManagerDriver.java | 42 +++++++++++++
.../flink/kubernetes/cli/KubernetesSessionCli.java | 6 +-
.../configuration/KubernetesConfigOptions.java | 8 +++
...bernetesResourceManagerDriverConfiguration.java | 13 +++-
.../entrypoint/KubernetesEntrypointUtils.java | 12 ++++
.../KubernetesResourceManagerFactory.java | 3 +-
.../kubeclient/Fabric8FlinkKubeClient.java | 70 ++++++++++++++++++++--
.../kubernetes/kubeclient/FlinkKubeClient.java | 20 ++++++-
.../decorators/InitJobManagerDecorator.java | 10 ++++
.../decorators/InitTaskManagerDecorator.java | 28 ++++++---
.../parameters/AbstractKubernetesParameters.java | 4 ++
.../kubeclient/resources/KubernetesService.java | 6 ++
.../apache/flink/kubernetes/utils/Constants.java | 3 +
.../flink/kubernetes/utils/KubernetesUtils.java | 6 ++
.../KubernetesResourceManagerDriverTest.java | 2 +-
.../kubeclient/Fabric8FlinkKubeClientTest.java | 47 +++++++++++++++
.../kubeclient/TestingFlinkKubeClient.java | 12 +++-
.../runtime/entrypoint/ClusterEntrypoint.java | 2 +
.../flink/runtime/util/ResourceManagerUtils.java} | 32 ++++++----
.../runtime/util/ResourceManagerUtilsTest.java | 58 ++++++++++++++++++
.../flink/yarn/YarnResourceManagerDriver.java | 22 ++-----
23 files changed, 364 insertions(+), 51 deletions(-)
copy
flink-runtime/src/{test/java/org/apache/flink/runtime/util/StartupUtils.java =>
main/java/org/apache/flink/runtime/util/ResourceManagerUtils.java} (54%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/util/ResourceManagerUtilsTest.java
