amplab/shark — pull request #245 by ChengXiangLi (2014-01-17 06:32:39+00:00)
Title: fix KryoSerializer NPE.

pull request #234 introduce an KryoSerializer NPE due to ser is not initialized in spark task,
java.lang.NullPointerException
at shark.execution.serialization.KryoSerializer$.deserialize(KryoSerializer.scala:49)
at shark.execution.serialization.OperatorSerializationWrapper.value(OperatorSerializationWrapper.scala:50)
at shark.execution.package$.opSerWrapper2op(package.scala:30)
at shark.execution.Operator$$anonfun$executeProcessPartition$1.apply(Operator.scala:336)
at shark.execution.Operator$$anonfun$executeProcessPartition$1.apply(Operator.scala:335)
at org.apache.spark.rdd.RDD$$anonfun$2.apply(RDD.scala:460)
at org.apache.spark.rdd.RDD$$anonfun$2.apply(RDD.scala:460)
at org.apache.spark.rdd.MapPartitionsRDD.compute(MapPartitionsRDD.scala:34)
at org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:241)
at org.apache.spark.rdd.RDD.iterator(RDD.scala:232)
at org.apache.spark.scheduler.ResultTask.runTask(ResultTask.scala:109)
at org.apache.spark.scheduler.Task.run(Task.scala:53)
at org.apache.spark.executor.Executor$TaskRunner$$anonfun$run$1.apply$mcV$sp(Executor.scala:213)
at org.apache.spark.deploy.SparkHadoopUtil.runAsUser(SparkHadoopUtil.scala:50)
at org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:178)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)