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 e196f7b [FLINK-19201][python][tests] Add retry logic for conda
install to avoid network problems
add 9367030 [FLINK-19626][table-planner-blink] Introduce multi-input
operator construction algorithm (#13742)
No new revisions were added by this update.
Summary of changes:
.../generated/optimizer_config_configuration.html | 6 +
.../table/api/config/OptimizerConfigOptions.java | 8 +
.../plan/processors/DeadlockBreakupProcessor.java | 52 +++
.../MultipleInputNodeCreationProcessor.java | 482 +++++++++++++++++++++
.../processors/utils/InputOrderCalculator.java | 85 ++++
.../utils/InputPriorityConflictResolver.java | 100 +++++
.../utils/InputPriorityGraphGenerator.java} | 219 ++--------
.../plan/processors/utils/TopologyGraph.java | 209 +++++++++
.../table/planner/delegation/BatchPlanner.scala | 21 +-
.../batch/BatchExecMultipleInputNode.scala | 4 +
.../plan/reuse/DeadlockBreakupProcessor.scala | 48 --
.../processors/utils/InputOrderCalculatorTest.java | 89 ++++
.../utils/InputPriorityConflictResolverTest.java | 89 ++++
.../utils/InputPriorityGraphGeneratorTest.java | 106 +++++
.../plan/processors/utils/TopologyGraphTest.java | 160 +++++++
.../reuse/InputPriorityConflictResolverTest.java | 185 --------
.../plan/batch/sql/MultipleInputCreationTest.xml | 395 +++++++++++++++++
.../plan/batch/sql/MultipleInputCreationTest.scala | 205 +++++++++
18 files changed, 2045 insertions(+), 418 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/DeadlockBreakupProcessor.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/MultipleInputNodeCreationProcessor.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/InputOrderCalculator.java
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/InputPriorityConflictResolver.java
rename
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/{reuse/InputPriorityConflictResolver.java
=> processors/utils/InputPriorityGraphGenerator.java} (52%)
create mode 100644
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/processors/utils/TopologyGraph.java
delete mode 100644
flink-table/flink-table-planner-blink/src/main/scala/org/apache/flink/table/planner/plan/reuse/DeadlockBreakupProcessor.scala
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/processors/utils/InputOrderCalculatorTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/processors/utils/InputPriorityConflictResolverTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/processors/utils/InputPriorityGraphGeneratorTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/processors/utils/TopologyGraphTest.java
delete mode 100644
flink-table/flink-table-planner-blink/src/test/java/org/apache/flink/table/planner/plan/reuse/InputPriorityConflictResolverTest.java
create mode 100644
flink-table/flink-table-planner-blink/src/test/resources/org/apache/flink/table/planner/plan/batch/sql/MultipleInputCreationTest.xml
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/plan/batch/sql/MultipleInputCreationTest.scala
