diff --git a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/PushDownFilterToScan.scala b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/PushDownFilterToScan.scala index 5eba9baa1c4d2..3ff098ae4b419 100644 --- a/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/PushDownFilterToScan.scala +++ b/gluten-substrait/src/main/scala/org/apache/gluten/extension/columnar/PushDownFilterToScan.scala @@ -36,13 +36,9 @@ object PushDownFilterToScan extends Rule[SparkPlan] with PredicateHelper { BackendsApiManager.getSparkPlanExecApiInstance.postProcessPushDownFilter( splitConjunctivePredicates(filter.cond), fileScan) - if (pushDownFilters.size > fileScan.dataFilters.size) { - val newScan = fileScan.copy(dataFilters = pushDownFilters) - if (newScan.doValidate().ok()) { - filter.withNewChildren(Seq(newScan)) - } else { - filter - } + val newScan = fileScan.copy(dataFilters = pushDownFilters) + if (newScan.doValidate().ok()) { + filter.withNewChildren(Seq(newScan)) } else { filter }