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 c55420b [FLINK-19941][kafka][table] Support sink parallelism
configuration for Kafka connector
add bbea2a5 [FLINK-19959][table-planner-blink] Multiple input creation
algorithm now considers related inputs when deducing input priorities
add 854f523 [FLINK-19959][table-planner-blink] Add IT cases for multiple
input
No new revisions were added by this update.
Summary of changes:
.../processors/utils/InputOrderCalculator.java | 87 +++
.../plan/processors/utils/TopologyGraph.java | 13 +
.../processors/utils/InputOrderCalculatorTest.java | 101 +++-
.../plan/processors/utils/TopologyGraphTest.java | 12 +
.../plan/batch/sql/MultipleInputCreationTest.xml | 636 ++++++++++++++++++++-
.../plan/batch/sql/MultipleInputCreationTest.scala | 63 +-
.../runtime/batch/sql/MultipleInputITCase.scala | 209 +++++++
7 files changed, 1108 insertions(+), 13 deletions(-)
create mode 100644
flink-table/flink-table-planner-blink/src/test/scala/org/apache/flink/table/planner/runtime/batch/sql/MultipleInputITCase.scala
