gpt4 book ai didi

apache-flink - 弗林克 : Watermarking with Late Elements

转载 作者:行者123 更新时间:2023-12-02 00:55:49 25 4
gpt4 key购买 nike

我正在 Flink 中进行实时流处理,其中 Kafka 是消息队列。我正在应用 120 秒的 EventTimeSlidingWindow。和1秒的幻灯片。我还在事件时间的每一秒插入水印。

我担心的是,如果元素迟到,在水印之后会发生什么?现在我的情况是,Flink 只是丢弃其各自水印之后的消息。 filnk 是否提供了任何机制来处理此类迟到的消息,例如维护单独的窗口?我也浏览了文档,但我没有弄清楚。

最佳答案

Apache Flink 有一个概念叫做 allowed lateness让窗口处理水印之后到达的数据。

关于apache-flink - 弗林克 : Watermarking with Late Elements,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/41734583/

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com