Flink on yarn startup procedure

graph TB
    A[用户提交Flink应用程序到YARN集群] 
    B[YARN ResourceManager分配ApplicationMaster]
    C[ApplicationMaster请求资源]
    D[ResourceManager分配资源给ApplicationMaster]
    E[ApplicationMaster启动JobManager和TaskManager]
    F[JobManager接收作业提交请求、调度任务执行和监控作业执行状态]
    G[TaskManager执行具体任务并返回执行结果给JobManager]
    H[Flink作业执行完毕，释放资源]
    I[ApplicationMaster通知ResourceManager释放资源]

    A --> B
    B --> C
    C --> D
    D --> E
    E --> F
    F --> G
    G --> H
    H --> I

    style A,B,C,D,E,F,G,H,I fill:#f9f,stroke:#333,stroke-width:2px

gdoc_arrow_left_alt 数据处理 flink wordcount gdoc_arrow_right_alt