前言
Filnk介绍及编程模型
Flink使用Java语言开发，提供scala编程接口。如果使用Java或Scala开发Flink，则必须使用jdk8版本。如果您使用Maven，则您的Maven版本必须为3.0.4或更高版本。
数据流：
并行数据流：
任务和操作员链：
作业管理器、任务管理器和客户端：
Flink保证消费数据的一致性
Flink 运行时包含两种类型的进程。
1、JobManger:（又称master）协调分布式执行、调度任务、协调检查点、协调灾难恢复。一个Flink程序至少有一个作业管理器，您可以配置多个作业管理器以实现高可用性。其中一名负责人担任领导，其他工作经理待命。
2、TaskManager:（也称为worker）执行数据流产生的任务，负责数据缓冲和任务管理器之间的数据交换。 Flink程序需要一个任务管理器。
Flink 程序可以运行在独立集群、Yarn 或Mesos 资源调度框架上。
客户端不是Flink 程序运行时的一部分。它的作用是准备数据流并将其发送给作业管理器。然后客户端可以断开连接或保持连接。
Flink的学习路线
Flink 1016.07M学习视频
Flink学习笔记
3336 0
flink代码及资料展示
600 10-69512
flink技术文档
版权声明：本文转载于网络，版权归作者所有。它属于。如有侵权，请联系本站编辑删除。