This is an automated email from the ASF dual-hosted git repository.
kkloudas pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 56ea8d1 [FLINK-17616][tests] Temporarily increase akka.ask.timeout in
TPC-DS e2e test
add e020d73 [FLINK-10934][client] Make flink run-application could
support local schema
add c84e48c [FLINK-10934][k8s] Support application mode for kubernetes
add 831ca0b [FLINK-10934][e2e] Add e2e tests for Kubernetes application
mode
add 1d9d0bf [FLINK-10934][dist] Set log4j for Kubernetes cli
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/client/cli/CliFrontend.java | 39 ++++--
.../flink/client/cli/ExecutionConfigAccessor.java | 4 +-
.../ClassPathPackagedProgramRetriever.java | 30 +++-
.../flink/client/program/PackagedProgramUtils.java | 11 ++
.../ClassPathPackagedProgramRetrieverTest.java | 29 ++++
.../client/program/PackagedProgramUtilsTest.java | 25 ++++
.../src/main/flink-bin/conf/log4j-cli.properties | 5 +
flink-end-to-end-tests/run-nightly-tests.sh | 1 +
.../test-scripts/common_kubernetes.sh | 21 +++
...s_session.sh => test_kubernetes_application.sh} | 50 ++-----
.../test-scripts/test_kubernetes_embedded_job.sh | 9 +-
.../test-scripts/test_kubernetes_session.sh | 9 +-
.../kubernetes/KubernetesClusterClientFactory.java | 4 +-
.../kubernetes/KubernetesClusterDescriptor.java | 40 +++++-
.../configuration/KubernetesDeploymentTarget.java | 35 +++--
.../KubernetesApplicationClusterEntrypoint.java | 69 ++++-----
.../KubernetesSessionClusterExecutor.java | 3 +-
.../flink/kubernetes/utils/KubernetesUtils.java | 22 +++
.../KubernetesClusterDescriptorTest.java | 154 +++++++++++++++------
.../KubernetesDeploymentTargetTest.java | 20 +--
20 files changed, 390 insertions(+), 190 deletions(-)
copy flink-end-to-end-tests/test-scripts/{test_kubernetes_session.sh =>
test_kubernetes_application.sh} (62%)
copy
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnDeploymentTarget.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesDeploymentTarget.java
(65%)
copy
flink-yarn/src/main/java/org/apache/flink/yarn/entrypoint/YarnApplicationClusterEntryPoint.java
=>
flink-kubernetes/src/main/java/org/apache/flink/kubernetes/entrypoint/KubernetesApplicationClusterEntrypoint.java
(64%)
copy
flink-yarn/src/test/java/org/apache/flink/yarn/configuration/YarnDeploymentTargetTest.java
=>
flink-kubernetes/src/test/java/org/apache/flink/kubernetes/configuration/KubernetesDeploymentTargetTest.java
(74%)
