Flink如何保证端到端的一致性

1、Flink如何保证端到端的一致性？

  • source端支持数据回放？
  • 内部一致性通过checkPoint保证？
  • sink端支持幂等写入，或者利用flink的事务写

https://juejin.cn/post/6844904070260457480

Flink

相关

Flink-环境部署

Flink连接Mysql的No suitable driver found for jdbc问题

FLINK-算子

Table API和Flink SQL

Flink 是如何统一批流引擎的

flink 代码编写建议

flink: org.codehaus.janino.CompilerFactory cannot be cast to org.codehaus.common

FLINK集群搭建

【记录】flink任务发布到yarn上报错Could not identify hostname and port in 'yarn-c

【Flink学习笔记】02、flink集群安装部署

Flink原理与实现：Flink中的状态管理，keygroup,namespace

05-Flink 运行时架构

标签