Fixed copy() method of GenericRow.

shefv · shefv · commit e09e898fbb17 · 2015-12-18T09:44:04.000+01:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/rows.scala
@@ -201,7 +201,7 @@ class GenericRow(protected[sql] val values: Array[Any]) extends Row {
 
   override def toSeq: Seq[Any] = values.toSeq
 
-  override def copy(): Row = this
+  override def copy(): Row = new GenericRow(values.clone())
 }
 
 class GenericRowWithSchema(values: Array[Any], override val schema: StructType)

Original file line number	Diff line number	Diff line change
`@@ -201,7 +201,7 @@ class GenericRow(protected[sql] val values: Array[Any]) extends Row {`
`201`	`201`
`202`	`202`	`override def toSeq: Seq[Any] = values.toSeq`
`203`	`203`
`204`		`- override def copy(): Row = this`
	`204`	`+ override def copy(): Row = new GenericRow(values.clone())`
`205`	`205`	`}`
`206`	`206`
`207`	`207`	`class GenericRowWithSchema(values: Array[Any], override val schema: StructType)`