Fix NotSerializableException

Author: zsxwing

streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobGenerator.scala

@@ -82,9 +82,7 @@ class JobGenerator(jobScheduler: JobScheduler) extends Logging {
     eventLoop = new EventLoop[JobGeneratorEvent]("JobGenerator") {
       override protected def onReceive(event: JobGeneratorEvent): Unit = processEvent(event)
 
-      override protected def onError(e: Throwable): Unit = {
-        jobScheduler.reportError("Error in job generator", e)
-      }
+      override protected def onError(e: Throwable): Unit = logError("Error in job generator", e)
     }
     eventLoop.start()
     if (ssc.isCheckpointPresent) {