This is an automated email from the ASF dual-hosted git repository.
snuyanzin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from b7a186b4553 [FLINK-38998][table] Fix cascaded event time
WindowAggregate does not produce data when offset is specified
add f16345aef7e [FLINK-39202][table] Add new
`SimplifyCoalesceWithEquiJoinConditionRule`
No new revisions were added by this update.
Summary of changes:
.../SimplifyCoalesceWithEquiJoinConditionRule.java | 308 +++++++++++++++++++++
.../planner/plan/rules/FlinkBatchRuleSets.scala | 4 +-
.../planner/plan/rules/FlinkStreamRuleSets.scala | 4 +-
...plifyCoalesceWithEquiJoinConditionRuleTest.java | 179 ++++++++++++
...mplifyCoalesceWithEquiJoinConditionRuleTest.xml | 305 ++++++++++++++++++++
5 files changed, 798 insertions(+), 2 deletions(-)
create mode 100644
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/rules/logical/SimplifyCoalesceWithEquiJoinConditionRule.java
create mode 100644
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/SimplifyCoalesceWithEquiJoinConditionRuleTest.java
create mode 100644
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/SimplifyCoalesceWithEquiJoinConditionRuleTest.xml
