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(-)