From 840cbcf849c27367bf2d8d316be8846f5a623d5d Mon Sep 17 00:00:00 2001 From: Matei Zaharia Date: Thu, 13 Sep 2012 17:19:26 -0700 Subject: Change default serializer to Java.. it had accidentally become Kryo. --- core/src/main/scala/spark/SparkEnv.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/spark/SparkEnv.scala b/core/src/main/scala/spark/SparkEnv.scala index b9efdbde64..7473b40aa3 100644 --- a/core/src/main/scala/spark/SparkEnv.scala +++ b/core/src/main/scala/spark/SparkEnv.scala @@ -72,7 +72,7 @@ object SparkEnv { System.setProperty("spark.master.port", boundPort.toString) } - val serializerClass = System.getProperty("spark.serializer", "spark.KryoSerializer") + val serializerClass = System.getProperty("spark.serializer", "spark.JavaSerializer") val serializer = Class.forName(serializerClass).newInstance().asInstanceOf[Serializer] val blockManagerMaster = new BlockManagerMaster(actorSystem, isMaster, isLocal) -- cgit v1.2.3