Flag that SparkSqlSerializer2 supports relocation

JoshRosen · JoshRosen · commit d3cc310de0e3 · 2015-05-01T14:47:33.000-07:00
diff --git a/core/src/test/resources/log4j.properties b/core/src/test/resources/log4j.properties
@@ -16,7 +16,7 @@
 #
 
 # Set everything to be logged to the file target/unit-tests.log
-log4j.rootCategory=INFO, file
+log4j.rootCategory=DEBUG, file
 log4j.appender.file=org.apache.log4j.FileAppender
 log4j.appender.file.append=true
 log4j.appender.file.file=target/unit-tests.log
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer2.scala
@@ -154,6 +154,8 @@ private[sql] class SparkSqlSerializer2(keySchema: Array[DataType], valueSchema:
   with Serializable{
 
   def newInstance(): SerializerInstance = new ShuffleSerializerInstance(keySchema, valueSchema)
+
+  override def supportsRelocationOfSerializedObjects: Boolean = true
 }
 
 private[sql] object SparkSqlSerializer2 {

Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@`
`16`	`16`	`#`
`17`	`17`
`18`	`18`	`# Set everything to be logged to the file target/unit-tests.log`
`19`		`-log4j.rootCategory=INFO, file`
	`19`	`+log4j.rootCategory=DEBUG, file`
`20`	`20`	`log4j.appender.file=org.apache.log4j.FileAppender`
`21`	`21`	`log4j.appender.file.append=true`
`22`	`22`	`log4j.appender.file.file=target/unit-tests.log`
Original file line number	Diff line number	Diff line change
`@@ -154,6 +154,8 @@ private[sql] class SparkSqlSerializer2(keySchema: Array[DataType], valueSchema:`
`154`	`154`	`with Serializable{`
`155`	`155`
`156`	`156`	`def newInstance(): SerializerInstance = new ShuffleSerializerInstance(keySchema, valueSchema)`
	`157`	`+`
	`158`	`+ override def supportsRelocationOfSerializedObjects: Boolean = true`
`157`	`159`	`}`
`158`	`160`
`159`	`161`	`private[sql] object SparkSqlSerializer2 {`