Flink基于EventTime和WaterMark处理乱序事件和晚到的数据(三)

在实际的业务中,咱们常常会遇到数据迟到的状况,这个时候基于窗口进行计算的结果就不对了,Flink中watermark就是为了解决这个问题的,理解watermark以前,先来讲一下flink中的三个与流数据相关的概念,ProcessTime、EventTime、IngestionTime,否则很难理解watermark是怎么回事.java 咱们先来看一下官网给出的一张图,很是形象地展现了Proces

>>阅读原文<<