话说在《Spark源代码分析之五:Task调度(一)》一文中,我们对Task调度分析到了DriverEndpoint的makeOffers()方法。这种方法针对接收到的ReviveOffers事件进行处理。代码例如以下: // Make fake resource offers on all exe ...
分类:
其他好文 时间:
2017-07-24 19:12:55
阅读次数:
262
话说在《Spark源码分析之五:Task调度(一)》一文中,我们对Task调度分析到了DriverEndpoint的makeOffers()方法。这个方法针对接收到的ReviveOffers事件进行处理。代码如下: 代码逻辑很简单,一共分为三步: 第一,从ex
分类:
其他好文 时间:
2016-03-14 08:21:18
阅读次数:
226
spark内核揭秘-06-TaskSceduler启动源码解析初体验
spark内核揭秘-06-TaskSceduler启动源码解析初体验
spark内核揭秘-06-TaskSceduler启动源码解析初体验
spark内核揭秘-06-TaskSceduler启动源码解析初体验...
分类:
其他好文 时间:
2015-01-19 19:06:45
阅读次数:
148