Skip to content

Commit 184c594

Browse files
committed
using executeCollect instead collect
1 parent 64f3175 commit 184c594

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -377,7 +377,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
377377
command.executeCollect().map(_.head.toString)
378378

379379
case other =>
380-
val result: Seq[Seq[Any]] = toRdd.map(_.copy()).collect().toSeq
380+
val result: Seq[Seq[Any]] = other.executeCollect().toSeq
381381
// We need the types so we can output struct field names
382382
val types = analyzed.output.map(_.dataType)
383383
// Reformat to match hive tab delimited output.

0 commit comments

Comments
 (0)