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 e7c11ed [FLINK-14746][web] Handle uncaught exceptions in
HistoryServerArchiveFetcher.
add 3aed29a [hotfix] Fix parallelism consolidation logic in the
(Stream)ExecutionEnvironment.
add fe2b2d6 [hotfix] Ignore empty yarn DYNAMIC_PROPERTIES when creating
configuration
add aae87a1 [hotfix] Make the DefaultExecutorServiceLoader a singleton
add 68a7987 [hotfix] Annotate all the Executor-related interfaces as
@Internal
add cac4b74 [hotfix] Annotate all ClusterClientFactories as @Internal
add 09b3d89 [hotfix] Make ClusterClientFactory.isCompatibleWith
case-insensitive
add 54e44b8 [hotfix] Simplify ContextEnvironment construction to use
configuration
add 3cb5921 [FLINK-14850] Update the Executor interface and introduce
minimal JobClient
add aad1131 [hotfix] Rename configuration param in constructor of
(Stream)ExecutionEnv
add 740de18 [FLINK-14851] Add the Yarn/Standalone Executors and make
ContextEnvironments use them
add 8379bc5 [FLINK-14851] Remove redundant CliFrontend.runProgram() method
add c1904e0 [FLINK-14851] Re-enabled the -sae flag.
add 3e8477d [FLINK-14851] Remove getJobSubmissionResult from JobClient
add 2c117ad [hotfix] Remove @nonnull annotatation from all the
Executor-related interfaces
add 5e8d5a8 [hotfix] Rename JobClientImpl to ClusterClientJobClientAdapter
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/client/ClientUtils.java | 31 ++----
.../client/cli/AbstractCustomCommandLine.java | 3 +-
.../org/apache/flink/client/cli/CliFrontend.java | 100 +-------------------
.../org/apache/flink/client/cli/DefaultCLI.java | 5 +-
.../deployment/AbstractJobClusterExecutor.java | 72 ++++++++++++++
.../deployment/AbstractSessionClusterExecutor.java | 67 +++++++++++++
.../client/deployment/ClusterClientFactory.java | 2 +
.../deployment/ClusterClientJobClientAdapter.java | 96 +++++++++++++++++++
.../flink/client/deployment/ExecutorUtils.java | 59 ++++++++++++
.../client/deployment/StandaloneClientFactory.java | 7 +-
.../StandaloneSessionClusterExecutor.java} | 35 +++----
.../StandaloneSessionClusterExecutorFactory.java} | 34 +++----
.../flink/client/program/ContextEnvironment.java | 104 +++++----------------
.../client/program/ContextEnvironmentFactory.java | 65 +++++--------
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
.../flink/client/cli/CliFrontendRunTest.java | 3 +-
.../deployment/ClusterClientServiceLoaderTest.java | 3 +-
.../apache/flink/client/program/ClientTest.java | 73 +++++++++++++--
.../client/program/rest/RestClusterClientTest.java | 2 +-
.../execution/DefaultExecutorServiceLoader.java | 14 ++-
.../execution}/DetachedJobExecutionResult.java | 14 +--
.../org/apache/flink/core/execution/Executor.java | 16 +++-
.../flink/core/execution/ExecutorFactory.java | 4 +-
.../core/execution/ExecutorServiceLoader.java | 4 +-
.../execution/{Executor.java => JobClient.java} | 25 +++--
.../flink/api/java/ExecutionEnvironment.java | 50 +++++++---
...java => ExecutorDiscoveryAndJobClientTest.java} | 54 +++++++----
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
.../test_execution_environment_completeness.py | 3 +-
.../api/environment/StreamContextEnvironment.java | 35 ++-----
.../environment/StreamExecutionEnvironment.java | 34 ++++---
...java => ExecutorDiscoveryAndJobClientTest.java} | 55 +++++++----
...org.apache.flink.core.execution.ExecutorFactory | 2 +-
.../BatchScalaAPICompletenessTest.scala | 3 +
.../flink/yarn/YarnClusterClientFactory.java | 10 +-
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 18 +++-
.../yarn/executors/YarnJobClusterExecutor.java | 38 +++-----
.../executors/YarnJobClusterExecutorFactory.java | 34 +++----
.../yarn/executors/YarnSessionClusterExecutor.java | 29 +++---
.../YarnSessionClusterExecutorFactory.java | 34 +++----
...org.apache.flink.core.execution.ExecutorFactory | 3 +-
.../flink/yarn/YarnClusterClientFactoryTest.java | 15 ++-
42 files changed, 752 insertions(+), 507 deletions(-)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractJobClusterExecutor.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/AbstractSessionClusterExecutor.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/ClusterClientJobClientAdapter.java
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/deployment/ExecutorUtils.java
copy flink-clients/src/main/java/org/apache/flink/client/{cli/DefaultCLI.java
=> deployment/executors/StandaloneSessionClusterExecutor.java} (54%)
copy flink-clients/src/main/java/org/apache/flink/client/{cli/DefaultCLI.java
=> deployment/executors/StandaloneSessionClusterExecutorFactory.java} (53%)
copy {flink-java/src/test =>
flink-clients/src/main}/resources/META-INF/services/org.apache.flink.core.execution.ExecutorFactory
(90%)
rename {flink-clients/src/main/java/org/apache/flink/client/program =>
flink-core/src/main/java/org/apache/flink/core/execution}/DetachedJobExecutionResult.java
(79%)
copy flink-core/src/main/java/org/apache/flink/core/execution/{Executor.java
=> JobClient.java} (58%)
rename
flink-java/src/test/java/org/apache/flink/api/java/{ExecutorDiscoveryTest.java
=> ExecutorDiscoveryAndJobClientTest.java} (64%)
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/environment/{ExecutorDiscoveryTest.java
=> ExecutorDiscoveryAndJobClientTest.java} (65%)
copy flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java
=>
flink-yarn/src/main/java/org/apache/flink/yarn/executors/YarnJobClusterExecutor.java
(50%)
copy flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java
=>
flink-yarn/src/main/java/org/apache/flink/yarn/executors/YarnJobClusterExecutorFactory.java
(54%)
copy
flink-core/src/main/java/org/apache/flink/core/execution/ExecutorFactory.java
=>
flink-yarn/src/main/java/org/apache/flink/yarn/executors/YarnSessionClusterExecutor.java
(54%)
copy flink-clients/src/main/java/org/apache/flink/client/cli/DefaultCLI.java
=>
flink-yarn/src/main/java/org/apache/flink/yarn/executors/YarnSessionClusterExecutorFactory.java
(54%)
copy {flink-streaming-java/src/test =>
flink-yarn/src/main}/resources/META-INF/services/org.apache.flink.core.execution.ExecutorFactory
(86%)
