flink-cdc SQL Server op 字段如何获取？
Flink CDC 是 Apache Flink 的组件，用于捕获数据库变更事件。对 SQL Server，通过 Debezium 连接器支持变更数据捕获。`op` 字段标识操作类型（INSERT、UPDATE、DELETE）。配置包括添加依赖及设定 Source 连接器，可通过 Flink SQL 或 Java/Scala 完成。示例查询利用 `op` 字段筛选处理变更事件。
Flink-Kafka-Connector Flink结合Kafka实战
简介
Flink-kafka-connector用来做什么？
Kafka中的partition机制和Flink的并行度机制结合，实现数据恢复Kafka可以作为Flink的source和sink任务失败，通过设置kafka的offset来恢复应用
kafka简单介绍
关于kafka，我们会有专题文章介绍，这里简单介绍几个必须知道的概念。
任务调度：时间轮算法经典案例解析及应用实现
平时大家的工作中应该会遇到较多需要在某个时间点执行某个任务，比如对运维来说，定时数据库的备份，日志和监控信息的抓取；比如业务系统，某个时间点给某个人群用户发放优惠券，甚至从操作系统角度，人机交互进程、视频播放的实时进程、批处理的后台进程等进程间的调度。。。
所以如何将这些任务高效、精准的调度？是任务调度系统中最重要的命题，当然在业务系统中一个完善的任务调度系统是很复杂的，需要具备能调度、可视化管理、过程可追溯、结果可分析、持久化、高可用等特性，这篇文章主要讨论任务调度逻辑，其余的内容我们后面文章探讨。
Spark - 一文搞懂 Partitioner
spark 处理 RDD 时提供了 foreachPartition 和 mapPartition 的方法对 partition 进行处理，一个 partition 内可能包含一个文件或者多个文件的内容，Partitioner 可以基于 pairRDD 的 key 实现自定义partition 的内容。