为何说coarseGrainedExecutorBackend要通讯的对象driverUrl是driverEndpoint而不是ClientEndpoint

背景:集群启动的时候启动了master和workerjava 用户提交程序时:apache 1. 首先new spark context,其中会new dagScheduler,taskSchedulerImpl和sparkDeploySchedulerBackend,并start taskSchedulerImpl。并发 2. 在taskSchedulerImpl start时,会start s
相关文章
相关标签/搜索