flink1.12.x 算子有成员变量时,该成员变量必须实现Serializable序列话接口
flink1.12.x 算子运算时,不要抛出异常,否则可能会导致其他算子无法继续运行,抛出Interrupted after 0 tries while maxAttempts=16异常
Flink CDC2.0 数据格式和op事件分类(c、u、d、r)
hbase2.1.x java 连接Hbase、关闭连接
大数据项目-金融审批实时数据仓库-DIM层运行、调试程序
Maxwell1.29.x type事件类型(bootstrap-start、bootstrap-complete、bootstrap-insert、insert、update、delete)
flink1.12.x source数据源-kafka,从头读取数据
kafka教程-从头消费数据:查看偏移量、删除偏移量
Flink CDC2.0 创建第一个工程
Flink 1.13 StateBackend 与 CheckpointStorage 拆分