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 14c140f [FLINK-12867][sql-parser] Add insert overwrite grammar as
HIVE dialect
new 4b5b09b [FLINK-12686][datastream] Remove StreamExecutionEnvironment
from StreamNode
new b8704a0 [FLINK-12686][datastream] Remove StreamExecutionEnvironment
from StreamGraph
new f95db6b [FLINK-12686][datastream] Remove StreamExecutionEnvironment
from StreamGraphGenerator
new 8524e22 [FLINK-12686][datastream] Add
StreamExecutionEnvironment.getStreamGraph(name)
new 4b80bf8 [FLINK-12686][datastream] Configure co-location group of
iteration nodes in StreamGraph instread of in StreamingJobGraphGenerator
new fec2ccf [FLINK-12832][datastream] Make slot sharing configurable in
StreamGraphGenerator
new 197edbf [FLINK-12832][datastream] Make ScheduleMode configurable in
StreamGraphGenerator
new 58b8cb0 [FLINK-12832][datastream] Use new StreamGraphGenerator
configurability in Blink Table Runner
The 8 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:
.../optimizer/plantranslate/JobGraphGenerator.java | 2 +-
.../jobmanager/scheduler/CoLocationGroup.java | 4 +
.../api/environment/LocalStreamEnvironment.java | 3 +-
.../api/environment/RemoteStreamEnvironment.java | 6 +-
.../api/environment/StreamContextEnvironment.java | 3 +-
.../environment/StreamExecutionEnvironment.java | 22 ++-
.../api/environment/StreamPlanEnvironment.java | 3 +-
.../flink/streaming/api/graph/StreamGraph.java | 75 ++++++---
.../streaming/api/graph/StreamGraphGenerator.java | 178 ++++++++++++++++-----
.../flink/streaming/api/graph/StreamNode.java | 34 ++--
.../api/graph/StreamingJobGraphGenerator.java | 22 +--
.../api/graph/StreamGraphGeneratorTest.java | 123 +++++++++++++-
.../api/graph/StreamingJobGraphGeneratorTest.java | 141 +++++++++++++++-
.../runtime/tasks/OneInputStreamTaskTest.java | 2 -
.../runtime/tasks/StreamConfigChainer.java | 8 +-
.../runtime/tasks/StreamTaskTestHarness.java | 4 +-
.../tasks/TwoInputStreamTaskTestHarness.java | 4 +-
.../client/gateway/local/ExecutionContext.java | 5 +-
.../flink/table/api/BatchTableEnvironment.scala | 39 +++--
.../flink/table/api/StreamTableEnvironment.scala | 12 +-
.../streaming/util/TestStreamEnvironment.java | 3 +-
.../ResumeCheckpointManuallyITCase.java | 3 +-
.../flink/test/checkpointing/SavepointITCase.java | 3 +-
23 files changed, 533 insertions(+), 166 deletions(-)
