Flink Timer（定时器）机制及实现详解
Timer是Flink Streaming API提供的用于感知并利用处理时间/事件时间变化的机制。官网上给出的描述如下:Timers are what make Flink streaming applications reactive and adaptable to processing and event time changes.
Apache 两个开源项目比较：Flink vs Spark
ApacheFlink是新一代通用大数据处理引擎，旨在统一不同的数据负载。这两个系统都旨在构建单一平台，可以在其中运行批处理，流媒体，交互式，图形处理，机器学习等。
Flink 通过 State Processor API 实现状态的读取和写入
在 1.9 版本之前，Flink 运行时的状态对于用户来说是一个黑盒，我们是无法访问状态数据的，从 Flink-1.9 版本开始，官方提供了 State Processor API 这让用户读取和更新状态成为了可能，我们可以通过 State Processor API 很方便的查看任务的状态，还可以在任务第一次启动的时候基于历史数据做状态冷启动。
Flink SQL 时区
大数据技术AI Flink/Spark/Hadoop/数仓，数据分析、面试，源码解读等干货学习资料 95篇原创内容 –>公众号TIMESTAMP vs TIMESTAMP_LTZTIMESTAMP 类型TIMESTAMP(p) 是 TIMESTAMP(p) WITHOUT TI
一文搞懂 FlinkX，基于flink的分布式数据同步工具
1 什么是FlinkXFlinkX是在是袋鼠云内部广泛使用的基于flink的分布式离线数据同步框架，实现了多种异构数据源之间高效的数据迁移。不同的数据源头被抽象成不同的Reader插件，不同的数据目标被抽象成不同的Writer插件。
Flink教程-flink 1.11 使用sql将流式数据写入文件系统
Key Default Type Description sink.rolling-policy.file-size 128MB MemorySize 分区文件的最大值，超过这个大小，将会启动一个新文件。
大数据_Flink_Java版_Table API 和 Flink SQL(9)_输出到其他外部系统
然后之前上一节我们看来,在flink中有3中更新模式,用来,比如追加模式用来:插入流数据,撤回模式,可以:add 可以delete 可以update对吧更新插入模式,可以 upsert对吧,然后可以delete删除消息我们之前,说往文件中插入数据,以及往kafka中输出数据,