This is an automated email from the ASF dual-hosted git repository.
tison pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7d375cc [FLINK-14993][metrics] Store delimiter in reporter settings
add 4ca5cdf [hotfix][yarn] Add AbstractClusterClientFactory containing
some common implementations
add 9781928 [hotfix][yarn] Move some common methods to
AbstractCustomCommandLine
add 912d256 [FLINK-10936][kubernetes] Implement Kubernetes command line
tools to support session cluster
No new revisions were added by this update.
Summary of changes:
.../client/cli/AbstractCustomCommandLine.java | 36 +++
.../org/apache/flink/client/cli/CliFrontend.java | 20 +-
...tory.java => AbstractClusterClientFactory.java} | 44 ++-
flink-kubernetes/pom.xml | 4 +-
.../kubernetes/KubernetesClusterClientFactory.java | 71 +++++
.../kubernetes/cli/FlinkKubernetesCustomCli.java | 332 +++++++++++++++++++++
.../KubernetesSessionClusterExecutor.java | 14 +-
.../KubernetesSessionClusterExecutorFactory.java | 9 +-
...he.flink.client.deployment.ClusterClientFactory | 2 +-
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
.../kubernetes/FlinkKubernetesCustomCliTest.java | 278 +++++++++++++++++
.../KubernetesClusterClientFactoryTest.java | 25 +-
.../flink/yarn/YarnClusterClientFactory.java | 29 +-
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 42 +--
14 files changed, 783 insertions(+), 125 deletions(-)
copy
flink-clients/src/main/java/org/apache/flink/client/deployment/{StandaloneClientFactory.java
=> AbstractClusterClientFactory.java} (52%)
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/KubernetesClusterClientFactory.java
create mode 100644
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/cli/FlinkKubernetesCustomCli.java
copy
flink-yarn/src/main/java/org/apache/flink/yarn/executors/YarnSessionClusterExecutor.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/executors/KubernetesSessionClusterExecutor.java
(72%)
copy
flink-clients/src/main/java/org/apache/flink/client/deployment/executors/StandaloneSessionClusterExecutorFactory.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/executors/KubernetesSessionClusterExecutorFactory.java
(83%)
copy {flink-yarn =>
flink-kubernetes}/src/main/resources/META-INF/services/org.apache.flink.client.deployment.ClusterClientFactory
(93%)
copy
flink-connectors/flink-connector-kafka-0.10/src/main/resources/META-INF/services/org.apache.flink.table.factories.TableFactory
=>
flink-kubernetes/src/main/resources/META-INF/services/org.apache.flink.core.execution.ExecutorFactory
(91%)
create mode 100644
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/FlinkKubernetesCustomCliTest.java
copy
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientFactoryTest.java
=>
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/KubernetesClusterClientFactoryTest.java
(61%)
