[Spark源码剖析] JobWaiter 2019年6月8日 Spark 0条评论 241次阅读 0人点赞 职责 等待DAGScheduler job完成,一个JobWaiter对象与一个job唯一一一对应 一旦task完成,将该task结果填充到SparkContext.runJob创建的results数组中 构造函数 pr…