Flink流计算编程--Flink中allowedLateness详细介绍及思考

一、简介 Flink中借助watermark以及window和trigger来处理基于event time的乱序问题,那么如何处理“late element”呢?java 也许有人会问,out-of-order element与late element有什么区别?不都是一回事么?web 答案是一回事,都是为了处理乱序问题而产生的概念。要说区别,能够总结以下:数据库 1、经过watermark机制来
相关文章
相关标签/搜索