fix test

Davies Liu · Davies Liu · commit 87b13cffdf8e · 2015-06-27T16:56:25.000-07:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/execution/ScriptTransformation.scala
@@ -167,7 +167,8 @@ case class ScriptTransformation(
 
               outputStream.write(data)
             } else {
-              val writable = inputSerde.serialize(row.asInstanceOf[GenericRow].values, inputSoi)
+              val writable = inputSerde.serialize(
+                row.asInstanceOf[GenericInternalRow].values, inputSoi)
               prepareWritable(writable).write(dataOutputStream)
             }
           }

Original file line number	Diff line number	Diff line change
`@@ -167,7 +167,8 @@ case class ScriptTransformation(`
`167`	`167`
`168`	`168`	`outputStream.write(data)`
`169`	`169`	`} else {`
`170`		`- val writable = inputSerde.serialize(row.asInstanceOf[GenericRow].values, inputSoi)`
	`170`	`+ val writable = inputSerde.serialize(`
	`171`	`+ row.asInstanceOf[GenericInternalRow].values, inputSoi)`
`171`	`172`	`prepareWritable(writable).write(dataOutputStream)`
`172`	`173`	`}`
`173`	`174`	`}`