apache-spark - 为什么 Spark JobScheduler 中出现空指针异常？

Question

我得到这个例外：

Exception in thread "pool-6-thread-1" java.lang.NullPointerException
  at org.apache.spark.streaming.scheduler.JobScheduler$JobHandler.run(JobScheduler.scala:173)
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
  at java.lang.Thread.run(Thread.java:722)

知道可能是什么原因造成的吗？我正在使用自定义接收器运行 Spark Streaming 作业。接收器停止，但仍有待处理的数据。

所以它在停止之前等待数据被处理。因为 stopGracefully 设置为 true。

但是在处理所有数据之前，我收到了这个错误。