Flink---13、容错机制（检查点（保存、恢复、算法、配置）、状态一致性、端到端精确一次）
容错机制（检查点（保存、恢复、算法、配置）、状态一致性、端到端精确一次）
flink日志实时采集写入Kafka/ElasticSearch
flink日志实时采集写入Kafka/ElasticSearch
从Flink的Kafka消费者看算子联合列表状态的使用
flink算子联合列表状态
大数据面试题：Spark和Flink的区别
Flink 根据用户提交的代码生成 StreamGraph，经过优化生成 JobGraph，然后提交给JobManager 进行处理， JobManager 会根据 JobGraph 生成 ExecutionGraph，ExecutionGraph 是 Flink 调度最核心的数据结构，JobMan
怎么使用 Flink 向 Apache Doris 表中写 Bitmap 类型的数据
Bitmap是一种经典的数据结构，用于高效地对大量的二进制数据进行压缩存储和快速查询。Doris支持bitmap数据类型，在Flink计算场景中，可以结合Flink doris Connector对bitmap数据做计算。社区里很多小伙伴在是Doris Flink Connector的时候，不知道怎
对比flink cdc和canal获取mysql binlog优缺点
Flink CDC和Canal都是用于获取MySQL binlog的工具，但是有以下几点优缺点对比：
Flink（java版）
时间语义和 watermark。
大数据系列——什么是Flink？Flink有什么用途？
Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行速度和任意规模来执行计算。支持高吞吐、低延迟(每秒处理百万个事件)、高性能的分布式处理框架。
Flink 系列三 Flink 实战
Flink 做为一款流式计算框架，它可用来做批处理，即处理静态的数据集、历史的数据集；也可以用来做流处理，即实时的处理些实时数据流，实时的产生数据流结果，只要数据源源不断的过来，Flink 就能够一直计算下去。Flink 系列二 Flink 状态化流处理概述Flink 系列一 开发机 安装。本篇作为
Doris实时数仓dim层构建
flink cdc实时同步mysql维表
spark 和 flink 的对比
的数据模型是(Resilient Distributed Dattsets)，这个内存数据结构使得spark可以通过固定内存做大批量计算。初期的 Spark Streaming 是通过(micro-batches)，即，所以严格意义上，还不能算作流式处理。
flink start AM request record
【代码】flink start AM request record。
修炼k8s+flink+hdfs+dlink（二：安装flink）
【代码】修炼k8s+flink+hdfs+dlink（一：安装flink）
flinkcdc同步完全量数据就不同步增量数据了
flinkcdc同步完全量数据就不同步增量数据了
Flink--8、时间语义、水位线（事件和窗口、水位线和窗口的工作原理、生产水位线、水位线的传递、迟到数据的处理）
时间语义、水位线（事件和窗口、水位线和窗口的工作原理、生产水位线、水位线的传递、迟到数据的处理）
【Flink】Flink 中的时间和窗口之水位线(Watermark)
在事件时间语义下，我们可以不依赖系统时间，而是基于数据自带的时间戳去定义了一个时钟，用来表示当前时间的进展。这样每个并行子任务都会有一个自己的逻辑时钟，它的前进是靠数据的时间戳来驱动的。但是在分布式系统中，会存在一些问题，因为数据本身在处理转换过程中会发生变化，如果遇到窗口聚合的操作，呢么下游的数据
Flink流批一体计算（16）：PyFlink DataStream API
图中的Operator Chain表示一个Operator，keyBy表示一个Operator，Sink表示一个Operator，它们通过Stream连接，而每个Operator在运行时对应一个Task，也就是说图中的上半部分有3个Operator对应的是3个Task。紧密度高的算子可以进行优化，优
32、Flink table api和SQL 之用户自定义 Sources & Sinks实现及详细示例
1、Flink 部署、概念介绍、source、transformation、sink使用示例、四大基石介绍和示例等系列综合文章链接13、Flink 的table api与sql的基本概念、通用api介绍及入门示例14、Flink 的table api与sql之数据类型: 内置数据类型以及它们的属性1
Flink CDC 基于mysql binlog 实时同步mysql表(无主键)
由于无主键， debezium.snapshot.mode' = 'initial',这个参数会导致，程序运行几次，源表数据就会同步几次到目标表，并不会去重，如果想一直这个参数运行，需要在插入前先清空表，但是如果是数据量大的，推荐还是先用这个参数同步历史数据，完成后，再改为 schema_only，
Flink文章汇总
Flink基础知识点博文汇总：Flink（1）：Flink概述Flink（2）：为什么选择FlinkFlink（3）：Flink安装部署之Local本地模式Flink（4）：Flink安装部署之Standalone独立集群模式Flink（5）：Flink安装部署之Standalone-HA高可用集
