File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
sql/core/src/main/scala/org/apache/spark/sql/execution Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change @@ -32,7 +32,13 @@ class SparkSqlSerializer(conf: SparkConf) extends KryoSerializer(conf) {
3232 kryo.setRegistrationRequired(false )
3333 kryo.register(classOf [MutablePair [_, _]])
3434 kryo.register(classOf [Array [Any ]])
35+ // This is kinda hacky...
3536 kryo.register(classOf [scala.collection.immutable.Map $Map1 ], new MapSerializer )
37+ kryo.register(classOf [scala.collection.immutable.Map $Map2 ], new MapSerializer )
38+ kryo.register(classOf [scala.collection.immutable.Map $Map3 ], new MapSerializer )
39+ kryo.register(classOf [scala.collection.immutable.Map $Map4 ], new MapSerializer )
40+ kryo.register(classOf [scala.collection.immutable.Map [_,_]], new MapSerializer )
41+ kryo.register(classOf [scala.collection.Map [_,_]], new MapSerializer )
3642 kryo.register(classOf [org.apache.spark.sql.catalyst.expressions.GenericRow ])
3743 kryo.register(classOf [org.apache.spark.sql.catalyst.expressions.GenericMutableRow ])
3844 kryo.register(classOf [scala.collection.mutable.ArrayBuffer [_]])
You can’t perform that action at this time.
0 commit comments