·用户提交的Flink Job会被转化成一个DAG任务运行,分别是:StreamGraph、JobGraph、ExecutionGraph
·Flink中JobManager与TaskManager,JobManager与Client的交互是基于Akka工具包的,是通过消息驱动
·整个Flink Job的提交还包含着ActorSystem的创建,JobManager的启动,TaskManager的启动和注册
标签:
笔试题
刷题
简历模板
AI算法
大数据
内推
内推: