开发者社区> 问答> 正文

用户提交的Flink Job会被转化成一个DAG任务运行,分别是什么呢?

用户提交的Flink Job会被转化成一个DAG任务运行,分别是什么呢?

展开
收起
游客vwuxaq6iqaowc 2021-12-08 14:42:38 565 0
1 条回答
写回答
取消 提交回答
  • 分别是:StreamGraph、JobGraph、ExecutionGraph,Flink中JobManager与TaskManager,JobManager与Client的交互是基于Akka工具包的,是通过消息驱动。整个Flink Job的提交还包含着ActorSystem的创建,JobManager的启动,TaskManager的启动和注册。

    2021-12-08 14:42:54
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载