回顾
上一篇，我们分析了了任务在executor端的运行流程，任务运行结束后，在Executor.launchTask方法最后，通过调用execBackend.statusUpdate方法将任务结果以及任务状态发送给driver。回到driver端，我们在driver的rpc服务端DriverEndPoint的receive方法中寻找对StatusUpdate消息的处理逻辑。上一篇，我们分析了了任务在executor端的运行流程，任务运行结束后，在Execu
阅读背景：
spark任务运行完成后在driver端的处理逻辑
来源：互联网
分享到：
