博客
关于我
flink分析使用之五工作图的生成和分发
阅读量:324 次
发布时间:2019-03-04

本文共 1203 字,大约阅读时间需要 4 分钟。

Flink??????JobGraph???????????????????????????????????????????????Flink???????????????

??????JobGraph???????

JobGraph ??Flink????????????????????????????

  • ?????????taskVertices?????????????????????????????
  • ?????jobConfiguration ????????????????
  • ??ID????jobID ? jobName ??????????????????
  • ?????????JAR?????????????????????????
  • ??????????????????????????
  • ?????scheduleMode ??????????????LAZY_FROM_SOURCES???????????

JobVertex ?????????????????????????????

  • ???????????????????????????
  • ????????inputs?results???????????????????
  • ?????????????????????????????

JobEdge ?????????????????????????????????????????????????????????????????

???????????

????Dispatcher? ?Flink?Standalone??????????????????SubmittedJobGraphStore???????????????????????

  • ?????????RPC??????????????????????????
  • ????????????????????????????????????????
  • ???????????????????????????????????????????

??????????

  • ?????????JobGraph???????????????????????DAG??
  • ?????????????????????JobManagerRunner???????
  • ??????????????????????????JobEdge?????
  • ???????????????????????????????????????
  • ????????????????????????
  • ????

    Flink???????????????????????????????????????????????????????????????????????????????????????Flink???????????????????????????????????

    转载地址:http://kxxq.baihongyu.com/

    你可能感兴趣的文章
    python基础之---面向对象--属性和方法
    查看>>
    python基础之---运算符
    查看>>
    python基础之---语句
    查看>>
    python基础之---正则表达式
    查看>>
    python基础之---函数式编程
    查看>>
    python基础之---函数
    查看>>
    Python基础之(一)基本数据类型
    查看>>
    Python基础【os】
    查看>>
    Python基础——面向对象
    查看>>
    Python基础——线程锁
    查看>>
    python基础——线程与进程
    查看>>
    Python基础——构造方法和特殊成员方法
    查看>>
    Python基础——多线程值从Thread类继承
    查看>>
    Python基础——多线程之信号量
    查看>>
    Python基础——_thread多线程
    查看>>
    Python基础——Thread类与线程对象
    查看>>
    Python基础——Thread创建管理多线程
    查看>>
    Python基础——SQLite数据库基本操作
    查看>>
    Python基础——MySQL数据库基本操作
    查看>>
    Python基础_列表 list
    查看>>