SparkStream源码分析：JobScheduler的JobStarted、JobCompleted是怎么被调用的

一，从StreamingContext.start()进入 ===>在SparkContext有一个JobScheduler成员会被初始化，JobScheduler会被StreamingContext.start()被调用 private[streaming]valscheduler =newJobScheduler(this) 二，跟进入JobScheduler的start（）方法，发现JobS

>>阅读原文<<