一、基本架构
client
将作业提交到jobmanager
JobManager
整个集群的master节点，负责整个flink集群的任务调度和资源管理，整个集群有且仅有一个活跃的JobManager。
从客户端获取提交的应用，根据TaskManager上TaskSlot使用情况，为提交的作业分配TaskSlot资源，并命令TaskManager启动应用。
所有checkpoints协调过程都在JobManager完成，每个taskmanager收到触发命令后，完成checkpoints操作。
TaskManager
负责具体任务执行和对应任务在每个节点资源的申请和管理
Flink数据类型
1.任意Java原生基本数据类型（装箱）
2.任意Java原生基本数据类型（装箱）数组
3.java Tuples
4.Scala Case Class
5.POJO
等