spark excutor 启动时序图
2021-02-25 23:09:22 1 举报spark excutor 启动时序图
作者其他创作
大纲/内容
TransportServer(netty)
new EndpointData()
new Inbox()
setupEndpoint()
new()
run()里面是while(true)
create()
createExecutorEnv()
take()
startServer()
CoarseGrainedExecutorBackend JVM
RpcEnv
EndpointData
MessageLoop: Thread
.inbox.process()
Inbox
run()
take()是阻塞的
receivers:LinkedBlockingQueue[EndpointData]
NettyRpcEnv
(object)CoarseGrainedExecutorBackend
offer(data)
data.inbox.process()
(class)CoarseGrainedExecutorBackend
createServer
main
new CoarseGrainedExecutorBackend( )
registerRpcEndpoint( )
Dispatcher
env.rpcEnv
offer()
TransportContext
create
NettyRpcEnvFactory
SparkEnv
0 条评论
下一页
