This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 747566d [FLINK-20007] SinkTransformationTranslator connect SinkWriter
to correct upstream node
add 07b6ed4 [FLINK-19756][table-planner] Rename
BatchExecMultipleInputNode/StreamExecMultipleInputNode to
BatchExecMultipleInput/StreamExecMultipleInput
add 5d8e171 [FLINK-19756][table-planner] Refactor
ExplainTest#testExplainMultipleInput method
add dc49dc7 [FLINK-19756][table-planner] Enable multiple input
optimization by default
No new revisions were added by this update.
Summary of changes:
.../generated/optimizer_config_configuration.html | 6 +-
.../table/api/config/OptimizerConfigOptions.java | 9 +-
.../MultipleInputNodeCreationProcessor.java | 12 +-
...nputNode.scala => BatchExecMultipleInput.scala} | 2 +-
...putNode.scala => StreamExecMultipleInput.scala} | 2 +-
.../resources/explain/testExplainMultipleInput.out | 44 --
.../apache/flink/table/api/batch/ExplainTest.xml | 124 +++++
.../flink/table/executor/BatchExecutorTest.xml | 59 --
.../planner/plan/batch/sql/DagOptimizationTest.xml | 68 +--
.../planner/plan/batch/sql/DeadlockBreakupTest.xml | 51 +-
.../planner/plan/batch/sql/LegacyLimitTest.xml | 598 ++++++++++-----------
.../plan/batch/sql/MultipleInputCreationTest.xml | 52 +-
.../planner/plan/batch/sql/RemoveCollationTest.xml | 182 +++----
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 284 +++++-----
.../planner/plan/batch/sql/SubplanReuseTest.xml | 140 +++--
.../batch/sql/agg/AggregateReduceGroupingTest.xml | 28 +-
.../plan/batch/sql/agg/GroupingSetsTest.xml | 22 +-
.../sql/join/BroadcastHashSemiAntiJoinTest.xml | 387 +++++++------
.../plan/batch/sql/join/JoinReorderTest.xml | 237 ++++----
.../batch/sql/join/NestedLoopSemiAntiJoinTest.xml | 585 ++++++++++----------
.../plan/batch/sql/join/SemiAntiJoinTest.xml | 384 ++++++-------
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 1 -
.../sql/join/ShuffledHashSemiAntiJoinTest.xml | 205 ++++---
.../plan/batch/sql/join/SingleRowJoinTest.xml | 9 +-
.../batch/sql/join/SortMergeSemiAntiJoinTest.xml | 208 ++++---
.../table/planner/plan/hint/OptionsHintTest.xml | 44 +-
.../plan/stream/table/TemporalTableJoinTest.xml | 90 ----
.../apache/flink/table/api/batch/ExplainTest.scala | 54 +-
.../plan/batch/sql/MultipleInputCreationTest.scala | 2 -
.../plan/metadata/FlinkRelMdHandlerTestBase.scala | 2 +-
.../runtime/batch/sql/MultipleInputITCase.scala | 2 +-
.../TableOperatorWrapperGenerator.java | 2 +-
32 files changed, 1768 insertions(+), 2127 deletions(-)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/batch/{BatchExecMultipleInputNode.scala
=> BatchExecMultipleInput.scala} (99%)
rename
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/nodes/physical/stream/{StreamExecMultipleInputNode.scala
=> StreamExecMultipleInput.scala} (98%)
delete mode 100644
flink-table/flink-table-planner-blink/src/test/resources/explain/testExplainMultipleInput.out
delete mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/executor/BatchExecutorTest.xml
delete mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/stream/table/TemporalTableJoinTest.xml
