Flink架构

1 Flink 任务提交流程 TaskManager是一个独立的jvm进程。 每个task slot表示TaskManager拥有资源的一个固定大小的子集。假如一个TaskManager有三个slot,那么它会将其管理的内存分成三份给各个slot。 slot就是运行在本进程下的独立资源集合,非线程概念,slot是cpu共享,内存隔离。一个slot并不代表一个线程,它里面并不一定只放一个task。多个task在一个slot就涉及slot sharing group。 2 Flink Yarn任务提交流程 代码就是stream Graph或者data Graph client生成job grap