本文共 178 字，大约阅读时间需要 1 分钟。

flink流程

1. 创建env，就是起一个环境
2. 添加源（就是数据从哪儿来），文件、socket、collection、addSource
3. 处理数据（transformation）
4. 消费数据（把数据放哪儿）files、sockets、external system、print、addSink

如何保持数据一致性

1. watermark
2. checkpoint

ref

转载地址：http://vaugf.baihongyu.com/