File tree Expand file tree Collapse file tree 2 files changed +2
-2
lines changed
core/src/main/scala/org/apache/spark/serializer Expand file tree Collapse file tree 2 files changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -127,7 +127,7 @@ class KryoSerializer(conf: SparkConf)
127127 }
128128
129129 private [spark] override lazy val supportsRelocationOfSerializedObjects : Boolean = {
130- // If auto-flush is disabled, then Kryo may store references to duplicate occurrences of objects
130+ // If auto-reset is disabled, then Kryo may store references to duplicate occurrences of objects
131131 // in the stream rather than writing those objects' serialized bytes, breaking relocation. See
132132 // https://groups.google.com/d/msg/kryo-users/6ZUSyfjjtdo/FhGG1KHDXPgJ for more details.
133133 newInstance().asInstanceOf [KryoSerializerInstance ].getAutoReset()
Original file line number Diff line number Diff line change @@ -23,7 +23,7 @@ import java.nio.ByteBuffer
2323import scala .reflect .ClassTag
2424
2525import org .apache .spark .{SparkConf , SparkEnv }
26- import org .apache .spark .annotation .{Private , Experimental , DeveloperApi }
26+ import org .apache .spark .annotation .{DeveloperApi , Private }
2727import org .apache .spark .util .{Utils , ByteBufferInputStream , NextIterator }
2828
2929/**
You can’t perform that action at this time.
0 commit comments