diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala index 7ba39d84bb65f..b3c9a19a68714 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/subquery.scala @@ -589,7 +589,7 @@ object RewriteCorrelatedScalarSubquery extends Rule[LogicalPlan] { } } } - (newChild, AttributeMap(subqueryAttrMapping)) + (newChild, AttributeMap(subqueryAttrMapping.toSeq)) } private def updateAttrs[E <: Expression](