gpt4 book ai didi

apache-flink - Flink 中的事件时间窗口不会触发

转载 作者:行者123 更新时间:2023-12-05 08:54:00 26 4
gpt4 key购买 nike

当我使用 flink 事件时间窗口时,窗口就是不触发。请问如何解决,有什么debug的方法吗?

最佳答案

由于您使用的是事件时间窗口,所以很可能是水印问题。该窗口仅在水印取得进展时输出。事件时间没有提前的原因有以下几点:

  1. 源头没有数据
  2. 其中一个源并行没有数据
  3. 从记录中提取的时间字段应该是毫秒而不是秒。
  4. 数据应覆盖比窗口大小更长的时间跨度,以提前事件时间。

如果我们将事件时间更改为处理时间,该窗口将输出。此外,我们可以通过检查网络仪表板中的水印来监控事件时间[1],或者使用可以查找当前水印的 ProcessFunction 对其进行打印调试。

[1] https://ci.apache.org/projects/flink/flink-docs-master/monitoring/debugging_event_time.html#monitoring-current-event-time

关于apache-flink - Flink 中的事件时间窗口不会触发,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/51691269/

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