zoukankan      html  css  js  c++  java
  • Flink集群Standalone启动脚本(源码分析)

    整个Flink集群的角色分为Jobmanager和TaskManager

    以Standalone为例来看一下脚本里面是怎样启动集群的

    找到源码的dist这里面包含了启动的脚本文件

    standalone模式下我们通过start-cluster.sh这个脚本启动

    来看下里面具体做了什么

    在最后调用了jobmanager.sh start 这个脚本和config.sh  中的TMSlaves 这个方法,分别启动了jobmanager和taskmanager

    先看一下Jobmanager

    在jobmanager.sh中导入了一些配置文件参数以外,脚本在最后执行了

    到了这个文件flink-daemon.sh 

    可以看到已经找到这样一个jobmanager的入口类org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint 了(1.6之前这里有较大的变化,详细的可以自己去研究一下)

    后面就是jobmanager的具体启动了

    现在在来看看TaskManager的启动方法config.sh 中 TMSlaves start

    taskmanager.sh中

    这里就和jobmanager的一样了,到了daemon.sh

    这就是taskmanagaer的入口类org.apache.flink.runtime.taskexecutor.TaskManagerRunner了

    整个集群jobmanager和taskmanager就启动起来了

    后面角色的具体启动后期会随缘更新

    来看一下window下的启动

    可以看到也差不多,都是走的这两个类作为启动类

  • 相关阅读:
    echo和tee的使用
    cut列的截取
    BZOJ1414: [ZJOI2009]对称的正方形(二维hash)
    BZOJ1010: [HNOI2008]玩具装箱toy
    BZOJ2588: Spoj 10628. Count on a tree(主席树)
    BZOJ3991: [SDOI2015]寻宝游戏(set+lca / 虚树)
    BZOJ2286: [Sdoi2011]消耗战(虚树)
    Linux
    奇妙的棋盘(建图+搜索)
    礼物(动态规划)
  • 原文地址:https://www.cnblogs.com/ljygz/p/11398761.html
Copyright © 2011-2022 走看看