首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

Flink 窗口 —— 允许迟到

但是,Flink允许指定窗口操作符的最大允许延迟时间。允许延迟指定元素在被删除之前可以延迟多长时间,其默认值为0。...到达的元素在水印经过窗口末端之后,但在它经过窗口末端加上允许的延迟之前,仍然被添加到窗口中。根据所使用的触发器,迟来但未删除的元素可能会导致窗口再次触发。...为了使这个工作,Flink保持窗口的状态直到它们允许的延迟过期。一旦发生这种情况,Flink就会删除窗口并删除其状态,这在window Lifecycle一节中也有描述。...默认情况下,允许的延迟设置为0。也就是说,到达水印后面的元素将被删除。...transformation>(); DataStream lateStream = result.getSideOutput(lateOutputTag); 迟到元素考虑 当指定一个允许的延迟大于

53920
领券