This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 46f8b59 [FLINK-14365][tests] Annotate MiniCluster tests in core
modules with AlsoRunWithSchedulerNG
new d632018 [FLINK-14290] Add Pipeline as a common base class of DataSet
and DataStream plans
new 8092daf [FLINK-14290] Add Pipeline translation utils for getting a
JobGraph from a FlinkPipeline
new fa872eb [FLINK-14290] Change DataSet PlanExecutors to use the new
pipeline translation util
new 55eb4b2 [FLINK-14290] Add support for StreamGraph to pipeline
translation util
new b47c13c [FLINK-14290] Use LocalExecutor in LocalStreamEnvironment
new 14b19dd [FLINK-14290] Add SavepointRestoreSettings to StreamGraph and
Generators
new 85e5a77 [FLINK-14290] Use RemoteExecutor in RemoteStreamEnvironment
new 3cdf06b [FLINK-14290] Use PipelineTranslationUtil and
client.submitJob() in StreamContextEnvironment
new ee8f930 [hotfix] Fix formatting/checkstyle in PlanExecutor
new eafdb64 [FLINK-14290] Move jars and classpath out of executors and
add to execute() method
new 98b54e0 [FLINK-14391] Factor out translator discovery in
FlinkPipelineTranslationUtil
new 70a8e0c [FLINK-14391] Add JobID setter in JobGraph
new 7084e07 [FLINK-14391] Add JSON execution graph generation to
PipelineTranslationUtil
new 835e776 [FLINK-14391] Remove JobID parameter from exception in
RemoteStreamEnvironment
new 59dd855 [FLINK-14391] Remove FlinkPlan as common base class of
OptimizerPlan and StreamGraph
The 15 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../java/org/apache/flink/client/ClientUtils.java | 16 +++
.../flink/client/FlinkPipelineTranslationUtil.java | 98 ++++++++++++++++++
.../flink/client/FlinkPipelineTranslator.java | 31 +++---
.../org/apache/flink/client/LocalExecutor.java | 111 +++++++++-----------
.../org/apache/flink/client/PlanTranslator.java | 99 ++++++++++++++++++
.../org/apache/flink/client/RemoteExecutor.java | 68 ++++++------
.../org/apache/flink/client/cli/CliFrontend.java | 20 +---
.../apache/flink/client/program/ClusterClient.java | 109 --------------------
.../flink/client/program/ContextEnvironment.java | 30 +++---
.../client/program/OptimizerPlanEnvironment.java | 28 ++---
.../flink/client/program/PackagedProgramUtils.java | 60 ++++++-----
.../RemoteExecutorHostnameResolutionTest.java | 8 +-
.../client/cli/CliFrontendPackageProgramTest.java | 7 +-
.../apache/flink/client/program/ClientTest.java | 24 +++--
.../client/program/ExecutionPlanCreationTest.java | 4 +-
.../java/org/apache/flink/api/common/Plan.java | 3 +-
.../org/apache/flink/api/common/PlanExecutor.java | 114 +++++++++++----------
.../{common/Archiveable.java => dag/Pipeline.java} | 13 +--
.../apache/flink/api/java/LocalEnvironment.java | 7 +-
.../apache/flink/api/java/RemoteEnvironment.java | 4 +-
.../org/apache/flink/optimizer/plan/FlinkPlan.java | 28 -----
.../apache/flink/optimizer/plan/OptimizedPlan.java | 2 +-
.../apache/flink/runtime/jobgraph/JobGraph.java | 9 +-
.../api/java/ScalaShellRemoteEnvironment.java | 4 +-
.../org/apache/flink/api/java/FlinkILoopTest.java | 13 +--
.../api/environment/LocalStreamEnvironment.java | 50 ++-------
.../api/environment/RemoteStreamEnvironment.java | 24 ++---
.../api/environment/StreamContextEnvironment.java | 20 +++-
.../api/environment/StreamPlanEnvironment.java | 2 +-
.../flink/streaming/api/graph/StreamGraph.java | 28 +++--
.../streaming/api/graph/StreamGraphGenerator.java | 9 +-
.../streaming/api/graph/StreamGraphTranslator.java | 69 +++++++++++++
.../api/graph/StreamingJobGraphGenerator.java | 2 +
.../RemoteStreamExecutionEnvironmentTest.java | 10 +-
.../api/graph/StreamGraphGeneratorTest.java | 18 ++++
.../api/graph/StreamingJobGraphGeneratorTest.java | 20 +++-
.../client/gateway/local/ExecutionContext.java | 40 +++++---
.../test/example/client/LocalExecutorITCase.java | 3 +-
38 files changed, 695 insertions(+), 510 deletions(-)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java
rename
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java
=>
flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslator.java
(53%)
create mode 100644
flink-clients/src/main/java/org/apache/flink/client/PlanTranslator.java
copy flink-core/src/main/java/org/apache/flink/api/{common/Archiveable.java =>
dag/Pipeline.java} (86%)
delete mode 100644
flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/FlinkPlan.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphTranslator.java
