You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by go...@apache.org on 2020/11/05 06:42:01 UTC

[flink] branch master updated (c55420b -> 854f523)

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