From ad74a06719f257679dd53608f0e4c8e4f9cfb8f2 Mon Sep 17 00:00:00 2001 From: Daniel Tenedorio Date: Thu, 9 Jan 2025 14:56:53 -0800 Subject: [PATCH] sync --- .../scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala index 49985ec717dd8..9282e0554a2d4 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala @@ -504,7 +504,7 @@ class Analyzer(override val catalogManager: CatalogManager) extends RuleExecutor */ object ResolveAliases extends Rule[LogicalPlan] { def apply(plan: LogicalPlan): LogicalPlan = - plan.resolveOperatorsUpWithPruning(_.containsAnyPattern(UNRESOLVED_ALIAS), ruleId) { + plan.resolveOperatorsUpWithPruning(_.containsPattern(UNRESOLVED_ALIAS), ruleId) { case Aggregate(groups, aggs, child, _) if child.resolved && AliasResolution.hasUnresolvedAlias(aggs) => Aggregate(groups, AliasResolution.assignAliases(aggs), child)