prepend the new qualifier

apache · Apr 17, 2015 · 5ee5d2c · 5ee5d2c
1 parent d2e8b43
commit 5ee5d2c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/basicOperators.scala
@@ -72,7 +72,8 @@ case class Generate(
     val withoutQualifier = if (join) child.output ++ generatorOutput else generatorOutput
 
     qualifier.map(q =>
-      withoutQualifier.map(_.withQualifiers(q :: Nil))
+      // prepend the new qualifier to the existed one
+      withoutQualifier.map(a => a.withQualifiers(q +: a.qualifiers))
     ).getOrElse(withoutQualifier)
   }
 }