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
