Hadoop-Yarn-NodeManager是如何启动容器的

02-27 1592阅读

一、源码下载

下面是hadoop官方源码下载地址,我下载的是hadoop-3.2.4,那就一起来看下吧

Hadoop-Yarn-NodeManager是如何启动容器的
(图片来源网络,侵删)

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
VPS购买请点击我

文章版权声明:除非注明,否则均为主机测评原创文章,转载或复制请以超链接形式并注明出处。

目录[+]