Re: Spark job endup with NPE

2015-08-14 Thread Akhil Das
at > org.apache.spark.executor.Executor$TaskRunner.run(Executor.scala:213) > at > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) > at > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)

Spark job endup with NPE

2015-08-14 Thread hide
:1145) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) at java.lang.Thread.run(Thread.java:745) Can I avoid this error by wrapping the word by scala.Option ? If anybody know why, please help me? Thanks,