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 9ba3b1a5863 [FLINK-31527][tests] Stabilize ChangelogRescalingITCase
     add e91eb5ec2fe [FLINK-31466][table] Apply Calcite's optimization of 
pushing filter to semijoin for FilterJoinRule

No new revisions were added by this update.

Summary of changes:
 .../plan/rules/logical/FlinkFilterJoinRule.java    | 27 +++++------
 .../sql/join/BroadcastHashSemiAntiJoinTest.xml     | 38 +++++++--------
 .../batch/sql/join/NestedLoopSemiAntiJoinTest.xml  | 50 +++++++++----------
 .../plan/batch/sql/join/SemiAntiJoinTest.xml       | 52 ++++++++++----------
 .../sql/join/ShuffledHashSemiAntiJoinTest.xml      | 42 ++++++++--------
 .../batch/sql/join/SortMergeSemiAntiJoinTest.xml   | 42 ++++++++--------
 .../logical/CalcPruneAggregateCallRuleTest.xml     | 16 +++----
 .../plan/rules/logical/FlinkFilterJoinRuleTest.xml |  9 ++--
 .../logical/ProjectPruneAggregateCallRuleTest.xml  | 56 ++++++++++++----------
 .../plan/stream/sql/join/SemiAntiJoinTest.xml      | 54 ++++++++++-----------
 .../stream/sql/SemiAntiJoinStreamITCase.scala      | 27 ++++++++++-
 11 files changed, 219 insertions(+), 194 deletions(-)

Reply via email to