Skip to content

Commit 6246dfa

Browse files
committed
small update.
1 parent c9ebfd0 commit 6246dfa

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

sql/core/src/test/scala/org/apache/spark/sql/execution/joins/HashedRelationSuite.scala

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -292,8 +292,7 @@ class HashedRelationSuite extends SparkFunSuite with SharedSQLContext {
292292
originalMap.append(key2, unsafeProj(InternalRow(value2)))
293293
originalMap.optimize()
294294

295-
val ser = new KryoSerializer(
296-
(new SparkConf).set("spark.kryo.referenceTracking", "false")).newInstance()
295+
val ser = sparkContext.env.serializer.newInstance()
297296
// Simulate serialize/deserialize twice on driver and executor
298297
val firstTimeSerialized = ser.deserialize[LongToUnsafeRowMap](ser.serialize(originalMap))
299298
val secondTimeSerialized =

0 commit comments

Comments
 (0)