Update sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ScanRelationPushDown.scala

cloud-fan · web-flow · commit 127e41253ab0 · 2021-12-31T13:23:39.000+08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ScanRelationPushDown.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/v2/V2ScanRelationPushDown.scala
@@ -212,7 +212,7 @@ object V2ScanRelationPushDown extends Rule[LogicalPlan] with PredicateHelper {
 
   private def supportPartialAggPushDown(agg: Aggregation): Boolean = {
     // We don't know the agg buffer of `GeneralAggregateFunc`, so can't do partial agg push down.
-    agg.aggregateExpressions().forall(!_.isInstanceOf[GeneralAggregateFunc])
+    agg.aggregateExpressions().exists(_.isInstanceOf[GeneralAggregateFunc])
   }
 
   private def addCastIfNeeded(aggAttribute: AttributeReference, aggDataType: DataType) =

Original file line number	Diff line number	Diff line change
`@@ -212,7 +212,7 @@ object V2ScanRelationPushDown extends Rule[LogicalPlan] with PredicateHelper {`
`212`	`212`
`213`	`213`	`private def supportPartialAggPushDown(agg: Aggregation): Boolean = {`
`214`	`214`	// We don't know the agg buffer of `GeneralAggregateFunc`, so can't do partial agg push down.
`215`		`- agg.aggregateExpressions().forall(!_.isInstanceOf[GeneralAggregateFunc])`
	`215`	`+ agg.aggregateExpressions().exists(_.isInstanceOf[GeneralAggregateFunc])`
`216`	`216`	`}`
`217`	`217`
`218`	`218`	`private def addCastIfNeeded(aggAttribute: AttributeReference, aggDataType: DataType) =`