[fix](nereids) fix regression case "nereids_p0/runtimefilter" (#29776)

This commit is contained in:
minghong
2024-01-10 18:36:27 +08:00
committed by yiguolei
parent a244f11da2
commit 99c8e47518
2 changed files with 2 additions and 1 deletions

View File

@ -370,6 +370,7 @@ public class RuntimeFilterGenerator extends PlanPostProcessor {
List<Expression> hashJoinConjuncts = join.getHashJoinConjuncts().stream().collect(Collectors.toList());
for (int i = 0; i < hashJoinConjuncts.size(); i++) {
// BE do not support RF generated from NullSafeEqual, skip them
if (hashJoinConjuncts.get(i) instanceof EqualTo) {
EqualTo equalTo = ((EqualTo) JoinUtils.swapEqualToForChildrenOrder(
(EqualTo) hashJoinConjuncts.get(i), join.left().getOutputSet()));