Shulou(Shulou.com)05/31 Report--

This article shows you how to carry out Worker Executor startup process source code analysis, the content is concise and easy to understand, absolutely can make your eyes bright, through the detailed introduction of this article, I hope you can get something.

Enter the Worker class source code:

You can see that Worker itself is an Actor in Akka.

Enter the LaunchExecutor of the Worker class:

You can see from the source code that to assign CPU and Memory to the new Executor on the Worker node, you first need to create an ExecutorRunner:

ExecutorRunner is used to maintain the executor process:

1. Enter the start method of ExecutorRunner:

2. Enter master! ExecutorStateChanged (appId, execId, manager.state, None, None) method:

Send a message to Master:

Let's go back to the launchExecutor method:

The above code sends the ExecutorStateChanged method to Master using Akka

Enter the ExecutorStateChanged method of Master:

PS: I feel that the code analysis is a little messy and not very ideal. I hope you all know, thank you.

Enter the LaunchExecutor of the Worker class:

1. Enter the start method of ExecutorRunner:

The above content is how to analyze the source code of Executor startup process in Worker. Have you learned the knowledge or skills? If you want to learn more skills or enrich your knowledge reserve, you are welcome to follow the industry information channel.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.