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 5c9d0d6 [FLINK-25810][connector/kinesis] Renaming e2e test module for
kinesis data streams.
add 546af84 [FLINK-25995][table-planner] Make implicit assumption of SQL
local hash explicit
No new revisions were added by this update.
Summary of changes:
.../planner/plan/nodes/exec/ExecNodeBase.java | 16 +-
.../planner/plan/nodes/exec/InputProperty.java | 55 ++++
.../plan/nodes/exec/batch/BatchExecExchange.java | 53 +++-
.../nodes/exec/batch/BatchExecMultipleInput.java | 14 +-
.../processor/ForwardHashExchangeProcessor.java | 171 +++++++++++
.../MultipleInputNodeCreationProcessor.java | 30 +-
.../table/planner/delegation/BatchPlanner.scala | 3 +-
.../batch/BatchPhysicalHashAggregate.scala | 10 +-
.../batch/BatchPhysicalHashWindowAggregate.scala | 10 +-
.../batch/BatchPhysicalOverAggregate.scala | 7 +-
.../batch/BatchPhysicalPythonGroupAggregate.scala | 10 +-
.../BatchPhysicalPythonGroupWindowAggregate.scala | 7 +-
.../batch/BatchPhysicalPythonOverAggregate.scala | 7 +-
.../nodes/physical/batch/BatchPhysicalRank.scala | 7 +-
.../batch/BatchPhysicalSortAggregate.scala | 9 +-
.../batch/BatchPhysicalSortMergeJoin.scala | 10 +-
.../batch/BatchPhysicalSortWindowAggregate.scala | 7 +-
.../plan/batch/sql/ForwardHashExchangeTest.java | 245 ++++++++++++++++
.../runtime/batch/ParallelismSettingTest.java | 93 ++++++
.../batch/sql/ForwardHashExchangeITCase.java | 81 ++++++
.../plan/batch/sql/ForwardHashExchangeTest.xml | 313 +++++++++++++++++++++
.../planner/plan/batch/sql/RemoveShuffleTest.xml | 70 +++++
.../planner/plan/batch/sql/RemoveShuffleTest.scala | 20 ++
23 files changed, 1195 insertions(+), 53 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/processor/ForwardHashExchangeProcessor.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/batch/sql/ForwardHashExchangeTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/ParallelismSettingTest.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/runtime/batch/sql/ForwardHashExchangeITCase.java
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/ForwardHashExchangeTest.xml
