Re-fix bug so that the tests pass again

JoshRosen · JoshRosen · commit e71c8664f298 · 2015-05-26T14:42:34.000-07:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/DataSourceStrategy.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/DataSourceStrategy.scala
@@ -309,7 +309,7 @@ private[sql] object DataSourceStrategy extends Strategy with Logging {
       output: Seq[Attribute],
       rdd: RDD[Row]): SparkPlan = {
     val converted = if (relation.needConversion) {
-      execution.RDDConversions.rowToRowRdd(rdd, relation.schema.map(_.dataType))
+      execution.RDDConversions.rowToRowRdd(rdd, output.map(_.dataType))
     } else {
       rdd
     }

Original file line number	Diff line number	Diff line change
`@@ -309,7 +309,7 @@ private[sql] object DataSourceStrategy extends Strategy with Logging {`
`309`	`309`	`output: Seq[Attribute],`
`310`	`310`	`rdd: RDD[Row]): SparkPlan = {`
`311`	`311`	`val converted = if (relation.needConversion) {`
`312`		`- execution.RDDConversions.rowToRowRdd(rdd, relation.schema.map(_.dataType))`
	`312`	`+ execution.RDDConversions.rowToRowRdd(rdd, output.map(_.dataType))`
`313`	`313`	`} else {`
`314`	`314`	`rdd`
`315`	`315`	`}`