filter condition

englefly · Jan 7, 2025 · 46a6653 · 46a6653
1 parent a74f3ad
commit 46a6653
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InferInPredicateFromOr.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/rewrite/InferInPredicateFromOr.java
@@ -55,8 +55,7 @@ public List<Rule> buildRules() {
 
     private LogicalFilter<Plan> rewriteFilterExpression(LogicalFilter<Plan> filter) {
         Expression rewritten = OrToIn.EXTRACT_MODE_INSTANCE.rewriteTree(filter.getPredicate());
-        Set<Expression> set = new LinkedHashSet<>();
-        set.add(rewritten);
+        Set<Expression> set = new LinkedHashSet<>(ExpressionUtils.extractConjunction(rewritten));
         return filter.withConjuncts(set);
     }