看下图： 为啥只有一个触发， WaterMark 时间 >= window结束时间 第一条日志 时间16:25:24 正好在 window [16:25:20 16:25:25) 里面，所以触发了，这里设置的水印延迟时间为10s 。
最后一条数据为什么没有触发，因为这个时候 window [16:25:25 16:25:30)，水印时间已经来到； 16:25:27 ，到达了第二条日志时间，然而
WaterMark 时间（16:25:27） < window结束时间（16:25:30） ,不触发
所以要触发水印，总结就是为2个条件：
1）watermark时间 >= window_end_time
2）在[window_start_time,window_end_time)中有数据存在
同时满足了以上2个条件，window才会触发。
watermark是一个全局的值，不是某一个key下的值，所以即使不是同一个key的数据，其warmark也会增加.
1，最近看书，结合一些视频，对水印的原理完全的理清楚了，也是个搬运工行为吧，希望做个总结，防止遗忘。 我们首先得知道watermaker的作用： 1）非常重要的作用是
一.简介 Flink提供了抽象，允许程序员分配自己的时间戳并发出自己的水印。更具体地说，根据使用情况，可以通过实现AssignerWithPeriodicWatermar
一.概述 生成时间戳/水印与在事件时间有关。有关事件时间， 处理时间和摄取时间，参考：[事件时间概述][Link 1] 为了处理事件时间，流式传输程序需要相应地设置时间
参考文档： [https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/metric
代码链接：[https://github.com/18113996630/flink-practice/blob/master/src/main/scala/com/hrong
Flink 简单入门示例 1.Flink读取Socket流，实现Word Count示例 import org.apache.flink.streaming
看下图： 为啥只有一个触发， WaterMark 时间 >= window结束时间 第一条日志 时间16:25:24 正好在 window \[16:25:20 16:2
> object KeyByDemo { > > > > def main(args: Array[String]): Uni
在用户代码中，我们设置生成水印和事件时间的方法assignTimestampsAndWatermarks（）中这里有个方法的重载 我们传入的对象分为两种：【2种生成水印的策略
悠悠
「爱情、让人受尽委屈。」
￡神魔★判官ぃ
Myth丶恋晨
还没有评论，来说两句吧...