watermark——late element疑问

来源:7-16 Flink watermark概述

bking3629688

2021-04-28

图片描述
推荐文章中提到迟到很多的数据,是有一条就触发一个window输出,但是我自己试了结果并没有输出。而且不是很理解,为什么迟到了的数据还要输出(Event_time<watertime),那不就是无限期等待迟到的数据了吗?感觉这里有点矛盾

写回答

1回答

bking3629688

提问者

2021-04-28

在文章下面的评论里找到了答案,好像大家都反馈这点是有问题的。迟到的数据应该侧边输出

0
1
Michael_PK
嗯嗯,迟到的数据使用侧流输出后,再单独进行处理的,不然的话,数据就丢失了,
2021-04-30
共1条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程