Skip to content

Commit 6ae00db

Browse files
committed
also fix problem with array
1 parent da1da09 commit 6ae00db

File tree

1 file changed

+6
-0
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis

1 file changed

+6
-0
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -256,6 +256,12 @@ class Analyzer(catalog: Catalog,
256256
case o => o :: Nil
257257
}
258258
Alias(UnresolvedFunction(name1, newClds), name2)() :: Nil
259+
case Alias(CreateArray(clds), name) if containsStar(clds) =>
260+
val newClds = clds.flatMap {
261+
case s: Star => s.expand(child.output, resolver)
262+
case o => o :: Nil
263+
}
264+
Alias(CreateArray(newClds), name)() :: Nil
259265
case o => o :: Nil
260266
},
261267
child)

0 commit comments

Comments
 (0)