Hi all, I changed spark.closure.serializer to kryo, when I try count action in 
spark shell the Task obj deserialize in Executor return null, src line is: 
override def run(){
......
task = ser.deserializer[Task[Any]](...)
......
}
Where task is null
Can any one help me? Thank you!

Reply via email to