kad*_*ank 4 apache-flink flink-streaming
我正在 Flink 中进行实时流处理，其中 Kafka 是消息队列。我正在应用 120 秒的 EventTimeSlidingWindow。和1秒的幻灯片。我还在事件时间的每一秒插入水印。
我担心的是，如果元素迟到，在水印之后会发生什么？现在我的情况是，Flink 只是丢弃其各自水印之后的消息。filnk 是否提供了任何机制来处理此类迟到的消息，例如维护单独的窗口？我也浏览了文档，但我没有弄清楚。
| 归档时间： |
|
| 查看次数： |
2161 次 |
| 最近记录： |