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 6a25bc5 [FLINK-14440][tests] Annotate BatchFineGrainedRecoveryITCase
to enable scheduler NG testing for it
add d00fe06 [FLINK-14502] Change CustomCommandLine cluster client methods
to get a configuration
add 71b056f [FLINK-14501] Change the log config file discovery
add 476b25a [FLINK-14501] Add the DeploymentOptions.TARGET
add 16d67e8 [FLINK-14501] Add the ClusterClientFactory and make it
discoverable
add d1aa63f [FLINK-14501] Add Standalone and Yarn ClusterClientFactories
add e444874 [FLINK-14501] Wired ClusterClientFactories to production code
add 3c8af45 [hotfix] Do not expose Yarn dynamic options
add bf955c5 [FLINK-14501] Make YarnClusterDescriptor initialization
self-contained
add ea6fdde [FLINK-14377] Parse the ProgramOptions to a Configuration.
add 20a0005 [hotfix] Rename T to ClusterID in CliFrontend and
ExecutionContext
add 9241af0 [FLINK-14502] Use the newly introduced list ConfigOption
wherever possible.
No new revisions were added by this update.
Summary of changes:
.../generated/deployment_configuration.html | 26 ++
.../generated/pipeline_configuration.html | 21 ++
.../generated/savepoint_config_configuration.html | 21 ++
.../generated/yarn_config_configuration.html | 40 +++
docs/ops/config.md | 9 +
docs/ops/config.zh.md | 9 +
.../client/cli/AbstractCustomCommandLine.java | 13 +-
.../org/apache/flink/client/cli/CliFrontend.java | 156 +++++----
.../apache/flink/client/cli/CliFrontendParser.java | 27 +-
.../apache/flink/client/cli/CustomCommandLine.java | 40 +--
.../org/apache/flink/client/cli/DefaultCLI.java | 30 +-
.../flink/client/cli/ExecutionConfigAccessor.java | 126 ++++++++
.../client/cli/ExecutionConfigurationUtils.java | 86 +++++
.../apache/flink/client/cli/ProgramOptions.java | 7 +-
.../client/deployment/ClusterClientFactory.java | 63 ++++
.../ClusterClientServiceLoader.java} | 19 +-
.../DefaultClusterClientServiceLoader.java | 75 +++++
.../client/deployment/StandaloneClientFactory.java | 59 ++++
...he.flink.client.deployment.ClusterClientFactory | 16 +
.../client/cli/CliFrontendPackageProgramTest.java | 93 +++---
.../flink/client/cli/CliFrontendRunTest.java | 53 ++-
.../flink/client/cli/CliFrontendTestBase.java | 6 +-
.../apache/flink/client/cli/DefaultCLITest.java | 38 +--
...andLine.java => DummyClusterClientFactory.java} | 47 ++-
...d.java => DummyClusterClientServiceLoader.java} | 25 +-
.../client/cli/util/DummyClusterDescriptor.java | 3 +-
.../client/cli/util/DummyCustomCommandLine.java | 34 +-
.../flink/client/cli/util/MockedCliFrontend.java | 5 +-
.../deployment/ClusterClientServiceLoaderTest.java | 167 ++++++++++
.../client/program/rest/RestClusterClientTest.java | 14 +-
...he.flink.client.deployment.ClusterClientFactory | 18 ++
.../flink/configuration/DeploymentOptions.java | 49 +++
.../flink/configuration/PipelineOptions.java | 53 +++
.../configuration/ConfigOptionsDocGenerator.java | 1 +
.../runtime/jobgraph/SavepointConfigOptions.java | 51 +++
.../runtime/jobgraph/SavepointRestoreSettings.java | 17 +
.../org/apache/flink/api/scala/FlinkShell.scala | 20 +-
.../client/gateway/local/ExecutionContext.java | 74 +++--
.../table/client/gateway/local/LocalExecutor.java | 20 +-
.../table/client/gateway/local/DependencyTest.java | 4 +-
.../client/gateway/local/LocalExecutorITCase.java | 10 +-
.../flink/yarn/CliFrontendRunWithYarnTest.java | 52 +--
.../java/org/apache/flink/yarn/YARNITCase.java | 2 -
.../apache/flink/yarn/YarnConfigurationITCase.java | 2 -
.../java/org/apache/flink/yarn/YarnTestBase.java | 1 -
.../util/NonDeployingYarnClusterDescriptor.java | 3 +-
.../flink/yarn/YarnClusterClientFactory.java | 97 ++++++
.../apache/flink/yarn/YarnClusterDescriptor.java | 125 ++++----
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 356 +++++++++------------
.../org/apache/flink/yarn/cli/YarnConfigUtils.java | 85 +++++
.../yarn/configuration/YarnConfigOptions.java | 54 ++++
.../configuration/YarnConfigOptionsInternal.java | 20 +-
...he.flink.client.deployment.ClusterClientFactory | 16 +
.../apache/flink/yarn/AbstractYarnClusterTest.java | 1 -
.../apache/flink/yarn/FlinkYarnSessionCliTest.java | 88 +++--
.../flink/yarn/YarnClusterClientFactoryTest.java | 47 +++
.../flink/yarn/YarnClusterDescriptorTest.java | 2 -
57 files changed, 1919 insertions(+), 677 deletions(-)
create mode 100644 docs/_includes/generated/deployment_configuration.html
create mode 100644 docs/_includes/generated/pipeline_configuration.html
create mode 100644 docs/_includes/generated/savepoint_config_configuration.html
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigAccessor.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/cli/ExecutionConfigurationUtils.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientFactory.java
rename
flink-clients/src/main/java/org/apache/flink/client/{cli/RunOptions.java =>
deployment/ClusterClientServiceLoader.java} (55%)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/DefaultClusterClientServiceLoader.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/StandaloneClientFactory.java
create mode 100644
flink-clients/src/main/resources/META-INF/services/org.apache.flink.client.deployment.ClusterClientFactory
copy
flink-clients/src/test/java/org/apache/flink/client/cli/util/{DummyCustomCommandLine.java
=> DummyClusterClientFactory.java} (53%)
copy
flink-clients/src/test/java/org/apache/flink/client/cli/util/{MockedCliFrontend.java
=> DummyClusterClientServiceLoader.java} (55%)
create mode 100644
flink-clients/src/test/java/org/apache/flink/client/deployment/ClusterClientServiceLoaderTest.java
create mode 100644
flink-clients/src/test/resources/META-INF/services/org.apache.flink.client.deployment.ClusterClientFactory
create mode 100644
flink-core/src/main/java/org/apache/flink/configuration/DeploymentOptions.java
create mode 100644
flink-core/src/main/java/org/apache/flink/configuration/PipelineOptions.java
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/SavepointConfigOptions.java
create mode 100644
flink-yarn/src/main/java/org/apache/flink/yarn/YarnClusterClientFactory.java
create mode 100644
flink-yarn/src/main/java/org/apache/flink/yarn/cli/YarnConfigUtils.java
rename
flink-clients/src/main/java/org/apache/flink/client/cli/InfoOptions.java =>
flink-yarn/src/main/java/org/apache/flink/yarn/configuration/YarnConfigOptionsInternal.java
(60%)
create mode 100644
flink-yarn/src/main/resources/META-INF/services/org.apache.flink.client.deployment.ClusterClientFactory
create mode 100644
flink-yarn/src/test/java/org/apache/flink/yarn/YarnClusterClientFactoryTest.java
