Skip to content

Commit 83e2611

Browse files
committed
Distinct-ify Attributes by exprId
Signed-off-by: Karen Feng <karen.feng@databricks.com>
1 parent 31f8bd0 commit 83e2611

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/optimizer/NestedColumnAliasing.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -242,7 +242,8 @@ object NestedColumnAliasing {
242242
exprList.foreach { e =>
243243
collectRootReferenceAndExtractValue(e).foreach {
244244
case ev: ExtractValue =>
245-
assert(ev.references.size == 1, s"$ev should have one reference")
245+
assert(ev.references.toSeq.map(_.exprId).distinct.size == 1,
246+
s"$ev should have one reference, but found ${ev.references}")
246247
nestedFieldReferences.append(ev)
247248
case ar: AttributeReference => otherRootReferences.append(ar)
248249
}

0 commit comments

Comments
 (0)