Hello, I'm trying to use kryo serialization with the required registration flag set to true via kryo.setRegistrationRequired(true).
I keep getting the following error saying that a certain class is not registered: java.lang.IllegalArgumentException: Class is not registered: com.my.package.MyClass[] Note: To register this class use: kryo.register(com.my.package.MyClass[].class); However, I do register it using kryo.register(classOf[MyClass[_]]) When I set Log.TRACE() I get the following output: 00:11 TRACE: [kryo] Register class ID 51: com.my.package.MyClass (com.esotericsoftware.kryo.serializers.FieldSerializer) I don't understand why it says it is not registered when the trace logger outputs that it has been registered. Has anyone experienced this before? The project I'm working on uses v0.8.1 -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Kyro-Registration-class-is-not-registered-but-Log-TRACE-says-otherwise-tp2077.html Sent from the Apache Spark User List mailing list archive at Nabble.com.
