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 cbfeef64e9b [FLINK-31414][checkpointing] make
BarrierAlignmentUtil.DelayableTimer not hidden exception
add 8990822bd77 [FLINK-31273][table-planner] Fix left join with IS_NULL
filter be wrongly pushed down and get wrong join results
No new revisions were added by this update.
Summary of changes:
.../plan/rules/logical/FlinkFilterJoinRule.java | 44 +-
.../rules/logical/FlinkFilterJoinRuleTest.java | 102 +++++
.../plan/batch/sql/join/BroadcastHashJoinTest.xml | 69 ++++
.../plan/batch/sql/join/NestedLoopJoinTest.xml | 214 +++++++---
.../plan/batch/sql/join/ShuffledHashJoinTest.xml | 335 +++++++++------
.../plan/batch/sql/join/SortMergeJoinTest.xml | 71 ++++
.../plan/rules/logical/FlinkFilterJoinRuleTest.xml | 456 ++++++++++++++++++++-
.../planner/plan/batch/sql/join/JoinTestBase.scala | 28 +-
.../plan/batch/sql/join/NestedLoopJoinTest.scala | 10 +-
.../runtime/batch/sql/join/JoinITCase.scala | 108 +++++
.../planner/runtime/stream/sql/JoinITCase.scala | 69 ++++
11 files changed, 1295 insertions(+), 211 deletions(-)
