Hadoop-Yarn-NodeManager是如何启动容器的
一、源码下载
下面是hadoop官方源码下载地址,我下载的是hadoop-3.2.4,那就一起来看下吧
(图片来源网络,侵删)
Index of /dist/hadoop/core
二、上下文
在我的博客中的NodeManager服务列表中有一项是ContainerManagerImpl,字面上也能看处理(容器管理实现),容器启动的逻辑就在这里。
三、开始捋源码
1、ContainerManagerImpl
public class ContainerManagerImpl extends CompositeService implements ContainerManager { //......省略...... public ContainerManagerImpl(Context context, ContainerExecutor exec, DeletionService deletionContext, NodeStatusUpdater nodeStatusUpdater, NodeManagerMetrics metrics, LocalDirsHandlerService dirsHandler) { //ContainerManager级调度程序 dispatcher = new AsyncDispatcher("NM ContainerManager dispatcher"); //创建ContainerLauncher,用于处理ContainerLauncherEvent containersLauncher = createContainersLauncher(context, exec); addService(containersLauncher); //......省略...... dispatcher.register(ContainersLauncherEventType.class, containersLauncher); } protected AbstractContainersLauncher createContainersLauncher( Context ctxt, ContainerExecutor exec) { //获取 yarn.nodemanager.containers-launcher.class 的值 默认值就是 ContainersLauncher //官方解释:容器启动器实现,用于确定如何在NodeManager中启动容器。 Class
文章版权声明:除非注明,否则均为主机测评原创文章,转载或复制请以超链接形式并注明出处。