From 50a68ca42058da46caff93ed1af925810555d994 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Wed, 6 May 2015 10:47:27 -0700 Subject: [PATCH] Address minor nits --- .../main/scala/org/apache/spark/serializer/KryoSerializer.scala | 2 +- .../src/main/scala/org/apache/spark/serializer/Serializer.scala | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala b/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala index d27bea48561f5..f9f78852f032b 100644 --- a/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala +++ b/core/src/main/scala/org/apache/spark/serializer/KryoSerializer.scala @@ -127,7 +127,7 @@ class KryoSerializer(conf: SparkConf) } private[spark] override lazy val supportsRelocationOfSerializedObjects: Boolean = { - // If auto-flush is disabled, then Kryo may store references to duplicate occurrences of objects + // If auto-reset is disabled, then Kryo may store references to duplicate occurrences of objects // in the stream rather than writing those objects' serialized bytes, breaking relocation. See // https://groups.google.com/d/msg/kryo-users/6ZUSyfjjtdo/FhGG1KHDXPgJ for more details. newInstance().asInstanceOf[KryoSerializerInstance].getAutoReset() diff --git a/core/src/main/scala/org/apache/spark/serializer/Serializer.scala b/core/src/main/scala/org/apache/spark/serializer/Serializer.scala index 4000f87d7ce12..6078c9d433ebf 100644 --- a/core/src/main/scala/org/apache/spark/serializer/Serializer.scala +++ b/core/src/main/scala/org/apache/spark/serializer/Serializer.scala @@ -23,7 +23,7 @@ import java.nio.ByteBuffer import scala.reflect.ClassTag import org.apache.spark.{SparkConf, SparkEnv} -import org.apache.spark.annotation.{Private, Experimental, DeveloperApi} +import org.apache.spark.annotation.{DeveloperApi, Private} import org.apache.spark.util.{Utils, ByteBufferInputStream, NextIterator} /**