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 2021/10/09 11:59:10 UTC

[flink] branch release-1.13 updated (4645c1d -> 4250543)

This is an automated email from the ASF dual-hosted git repository.

godfrey pushed a change to branch release-1.13
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 4645c1d  [hotfix] Fix incorrect state.backend.local-recovery description
     add 4250543  [FLINK-22954][table-planner-blink] Rewrite Join on constant TableFunctionScan to Correlate

No new revisions were added by this update.

Summary of changes:
 .../JoinTableFunctionScanToCorrelateRule.java      |  64 +++++++++++++
 .../planner/plan/rules/FlinkStreamRuleSets.scala   |   4 +-
 ...reamPhysicalConstantTableFunctionScanRule.scala |   2 +-
 .../utils/JavaUserDefinedTableFunctions.java       |   5 +-
 .../planner/plan/stream/table/CorrelateTest.xml    | 104 +++++++++++++++++++--
 .../planner/plan/stream/table/CorrelateTest.scala  |  58 +++++++++++-
 .../runtime/stream/sql/CorrelateITCase.scala       |  64 ++++++++++++-
 7 files changed, 284 insertions(+), 17 deletions(-)
 create mode 100644 flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/plan/rules/logical/JoinTableFunctionScanToCorrelateRule.java