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 6e80a83 [FLINK-13990][coordination] Remove legacy exceptions
add 790fe27 [FLINK-13946] Remove session-related code from execution env
add 9753614 [FLINK-13946] Remove session-related code from the
PlanExecutors
add c746cbb [FLINK-13946] Refactor executor code to ban resource sharing
between plan executions.
add 80fa99d [FLINK-13946] Remove unused constructors from RemoteExecutor
add e8650cd [FLINK-13946] Make the ClusterClient autocloseable
add 2c38a9b [FLINK-13946] Remove taskManagerNumSlots and
defaultOverwriteFiles from LocalExecutor
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/client/LocalExecutor.java | 176 +++++----------------
.../org/apache/flink/client/RemoteExecutor.java | 105 +-----------
.../org/apache/flink/client/cli/CliFrontend.java | 6 +-
.../apache/flink/client/program/ClusterClient.java | 12 +-
.../flink/client/program/ContextEnvironment.java | 9 +-
.../client/program/OptimizerPlanEnvironment.java | 5 -
.../client/program/PreviewPlanEnvironment.java | 4 -
.../client/program/rest/RestClusterClient.java | 8 +-
.../flink/client/cli/CliFrontendSavepointTest.java | 12 +-
.../client/program/rest/RestClusterClientTest.java | 18 +--
.../org/apache/flink/api/common/PlanExecutor.java | 32 +---
.../flink/api/java/CollectionEnvironment.java | 4 -
.../flink/api/java/ExecutionEnvironment.java | 72 +--------
.../apache/flink/api/java/LocalEnvironment.java | 151 ++----------------
.../apache/flink/api/java/RemoteEnvironment.java | 97 +-----------
.../api/java/ScalaShellRemoteEnvironment.java | 30 ++--
.../org/apache/flink/api/scala/FlinkShell.scala | 2 +-
.../org/apache/flink/api/java/FlinkILoopTest.java | 15 --
.../flink/api/scala/ExecutionEnvironment.scala | 50 +-----
.../api/environment/RemoteStreamEnvironment.java | 2 +-
.../table/client/gateway/local/LocalExecutor.java | 2 +-
.../client/gateway/local/ProgramDeployer.java | 4 +-
.../test/util/MiniClusterWithClientResource.java | 2 +-
.../apache/flink/test/util/TestEnvironment.java | 4 -
.../test/example/client/JobRetrievalITCase.java | 2 +-
.../test/example/client/LocalExecutorITCase.java | 12 +-
.../jsonplan/JsonJobGraphGenerationTest.java | 4 -
.../recovery/ProcessFailureCancelingITCase.java | 2 +-
.../runtime/BigUserProgramJobSubmitITCase.java | 2 +-
.../flink/yarn/YARNHighAvailabilityITCase.java | 4 +-
.../java/org/apache/flink/yarn/YARNITCase.java | 2 +-
.../apache/flink/yarn/YarnConfigurationITCase.java | 2 +-
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 4 +-
33 files changed, 134 insertions(+), 722 deletions(-)
