in the dsl, create a new schema instance in each applySchema

Eric Liang · Eric Liang · commit 05bd1e41ae60 · 2014-09-03T19:05:08.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala b/sql/core/src/main/scala/org/apache/spark/sql/SchemaRDD.scala
@@ -428,7 +428,8 @@ class SchemaRDD(
    */
   private def applySchema(rdd: RDD[Row]): SchemaRDD = {
     new SchemaRDD(sqlContext,
-      SparkLogicalPlan(ExistingRdd(queryExecution.analyzed.output, rdd))(sqlContext))
+      SparkLogicalPlan(
+        ExistingRdd(queryExecution.analyzed.output.map(_.newInstance), rdd))(sqlContext))
   }
 
   // =======================================================================

Original file line number	Diff line number	Diff line change
`@@ -428,7 +428,8 @@ class SchemaRDD(`
`428`	`428`	`*/`
`429`	`429`	`private def applySchema(rdd: RDD[Row]): SchemaRDD = {`
`430`	`430`	`new SchemaRDD(sqlContext,`
`431`		`- SparkLogicalPlan(ExistingRdd(queryExecution.analyzed.output, rdd))(sqlContext))`
	`431`	`+ SparkLogicalPlan(`
	`432`	`+ ExistingRdd(queryExecution.analyzed.output.map(_.newInstance), rdd))(sqlContext))`
`432`	`433`	`}`
`433`	`434`
`434`	`435`	`// =======================================================================`