From f114f08a628b98f7e713c692fa4f7d4c10d253c0 Mon Sep 17 00:00:00 2001 From: Dongjoon Hyun Date: Fri, 24 Jun 2016 18:50:29 -0700 Subject: [PATCH] [SPARK-16173] [SQL] Can't join describe() of DataFrame in Scala 2.10 --- sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala index 1beb080f81d4a..8884daa301179 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala @@ -1363,7 +1363,8 @@ class DataFrame private[sql]( // All columns are string type val schema = StructType( StructField("summary", StringType) :: outputCols.map(StructField(_, StringType))).toAttributes - LocalRelation.fromExternalRows(schema, ret) + // `toArray` forces materialization to make the seq serializable + LocalRelation.fromExternalRows(schema, ret.toArray.toSeq) } /**