Skip to content

Commit 5ee5d2c

Browse files
prepend the new qualifier
1 parent d2e8b43 commit 5ee5d2c

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/plans/logical/basicOperators.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,8 @@ case class Generate(
7272
val withoutQualifier = if (join) child.output ++ generatorOutput else generatorOutput
7373

7474
qualifier.map(q =>
75-
withoutQualifier.map(_.withQualifiers(q :: Nil))
75+
// prepend the new qualifier to the existed one
76+
withoutQualifier.map(a => a.withQualifiers(q +: a.qualifiers))
7677
).getOrElse(withoutQualifier)
7778
}
7879
}

0 commit comments

Comments
 (0)