基于Flink的实时计算平台的构建消息队列的数据既是离线数仓的原始数据 ， 也是实时计算的原始数据，这样可以保证实时和离线的原始数据是统一的 。
像Flink 、 Spark Streaming 这类包含状态的实时计算框架，需要恢复 Master 节点的同时还需要对其状态进行恢复，Master 状态信息包含一些必要的配置、以及对 Slave 节点状态管理的信息（如“某个 Slave 节点的状态快照所在的 HDFS 路径”） 。
【flink mysqlsink flinksql读取mysql数据】Flink程序是由Stream和Transformation这两个基本构建块组成，其中Stream是一个中间结果数据，而Transformation是一个操作，它对一个或多个输入Stream进行计算处理，输出一个或多个结果Stream 。Flink程序被执行的时候 ， 它会被映射为Streaming Dataflow 。
Flink在德语中是快速和灵敏的意思，用来体现流式数据处理速度快和灵活性强等特点 。
flinksql-core-动态表普通动态表是FlinkSQL中的一类表，表中的数据与连接的外部数据对等，可以简单理解为把一张mysql的表放进flink内存中得到的表 ， 并且该表与mysql表有连接关系，即该表可以读写mysql表 。
mysql同步数据到hive---binlog方式想问下原来数据库中的数据会不会有更新和删除 ， 如果有的话，想实时同步到hive中很难 。另外即使能实时同步到hive中，hive中分析查询也速度也比较慢的 。
MySQL replication是通过将主机上的binlog（二进制日志）事件传输到从机来进行数据同步的 。在MySQL复制中 ， 主机上的写操作将被记录到binlog中 。
实现两个Mysql数据库之间同步同步原理：MySQL为了实现replication必须打开bin-log项，也是打开二进制的MySQL日志记录选项 。
增量同步主要分为两步，第一步，存量数据一次性同步；第二步，在存量数据的基础之上，做增量；后期的每一次同步都是增量同步 。
11-flink读写MySQL利用mysql proxy来实现的 。MySQL Proxy最强大的一项功能是实现“读写分离（Read/Write Splitting）” 。基本的原理是让主数据库处理事务性查询，而从数据库处理SELECT查询 。
update、delete），则直接操作 主库 ；如果是 读操作 （select） ，则直接操作从库 ， 这种结构就是 读写分离 啦 。
limit接受一个或两个数字参数 。参数必须是一个整数常量 。如果给定两个参数，第一个参数指定第一个返回记录行的偏移量，第二个参数指定返回记录行的最大数目 。
flinksql字段只看顺序是的 。flinksql可以通过create语句控制字段个数和顺序，决定后面insertinto的select语句中的字段顺序受影响 ， 所以insertinto的select只能跟create定义的顺序一样 ， 不能改别名 。
其中字段定义时还可以声明表主键，声明语法为PARIMARY KEY（myColumn1，...） NOT ENFORCED，这里的not enforced表示flinksql不会对主键做强制的唯一性约束、非空约束 ， 而且目前flinksql中只支持这种类型的主键 。
在SQL中，使用GROUP BY 分组 ， SELECT 查询中的列必须在GROUP BY 中出现，不然会报错但 ， GROUP BY 后面的列，不一定要在前面查询中出现 。INNER JOIN 可以和GROUP BY 一起使用 。
推荐阅读
- 如何查找自己的服务器？ 怎么找自己的服务器
- 网吧服务器性能如何？ 网吧服务器怎么样啊
- 智合云服务器传销 智合云服务器怎么买
- mysql存储过程for mysql如何在存储过程中遍历表
- mysql查询表数量 mysql怎么查询表中有多少记录
- mysql数据库数据导入 mysql数据库导入导出教程
- 如何查找自己的腾讯云服务器？ 怎么找自己的腾讯服务器