Flink极客训练营Day2

可以不写出，因为存在state状态。 A连接外部系统，将外部数据读入flink。C连接外部系统，将数据写入。 存在乱序时，通过插入watermark来使得数据看起来似乎正确，比如插入大小为3的watermark，就是判断认为不会再有比3小的数据传过来了。 watermark的设计思路可为eventTime - 5s。 多流watermark都shuffle到同一个处理节点时，为了保证单调自增，会选

>>阅读原文<<