【Flink】1.Flink集群部署
flink集群部署：standalone和flink-on-yarn
Flink Kafka-Source
Flink Kafka-Source
6、Flink四大基石之Window详解与详细示例（一）
流计算中一般在对流数据进行操作之前都会先进行开窗，即基于一个什么样的窗口上做这个计算。Flink提供了开箱即用的各种窗口，比如滑动窗口、滚动窗口、会话窗口以及非常灵活的自定义的窗口。在流处理应用中，数据是连续不断的，有时需要做一些聚合类的处理，例如在过去的1分钟内有多少用户点击了我们的网页。在这种情
flink数据延迟原因及详细处理方案
在java开发中flink遇到数据延迟到达的问题及解决方案
Flink是什么
其中，JobManager和TaskManager进程是Flink的核心进程，负责实际的任务执行和作业管理。Flink是一个分布式的、高性能的、可伸缩的、容错的流处理引擎，它支持批处理和流处理，并提供了丰富的API和库，是实时数据处理的理想选择。JobManager进程：负责接收提交的作业并分配任务
13、Flink 的table api与sql的基本概念、通用api介绍及入门示例
Apache Flink 有两种关系型 API 来做流批统一处理：Table API 和 SQL。Table API 是用于 Scala 和 Java 语言的查询API，它可以用一种非常直观的方式来组合使用选取、过滤、join 等关系型算子。Flink SQL 是基于 Apache Calcite
1分钟理解Flink中Watermark机制
1分钟理解Flink中Watermark
Flink CDC实时同步PG数据库
Flink CDC同步PG数据库全流程
CDH 6.3.2下安装Flink
cdh 6.3.2下安装flink简单教程，自己在生产环境中测试成功
Flink使用 KafkaSource消费 Kafka中的数据
很多 flink相关的书籍和网上的文章讲解如何对接 kafka时都是使用的 FlinkKafkaConsume，'org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer' is deprecated ，新版 flink应该使用 K
Flink CDC 基于Oracle log archiving 实时同步Oracle表到Mysql（无主键）
现在操作的是源表和目标表都无主键数据实时同步，其实是在flink建立和sink表的关联时，指定了主键，只不过是flink实时同步程序的需要，sink目标表没有主键。// 这使得LogMiner的挖掘速度大大提高，但代价是无法跟踪DDL的变化。//online_catalog -使用数据库的当前数据字
如何解决Flink任务的数据倾斜
如何解决flink任务的数据倾斜问题
Flink生产数据到kafka
Flink程序生产数据至kafka。
Flink CDC2.4 整库实时同步MySql 到Doris
mysql 到doris的数据、表结构实时同步
大数据Flink（五十二）：Flink中的批和流以及性能比较
Spark和Flink全部都运行在Hadoop YARN上，性能为Flink > Spark > Hadoop(MR)，迭代次数越多越明显，性能上，Flink优于Spark和Hadoop最主要的原因是Flink支持增量迭代，具有对迭代自动优化的功能。也即是有明确的开始和结束的定义。注入的顺序不是必须
Flink 状态后端
状态后端 (state backend) : 负责管理本地状态的存储方式, 位置。
Flink读取数据的5种方式（文件，Socket，Kafka，MySQL，自定义数据源）
当需要对Flink进行一些性能测试时，可以使用自定义数据源来简化测试过程。Flink支持自定义数据源，可以使用循环生成所需要格式的测试数据，使用方式非常灵活。运行程序后，会产生源源不断的数据。
FlinkSql写入/读取Kafka
FlinkSql写入/读取Kafka
flink时间窗口无新的数据进来最后一个窗口不关闭
flink最后一个窗口不会闭窗计算
Flink stop 和 cancel停止 job 的区别
Flink stop 和 cancel停止 job 的区别
