Re: keyby后滚动窗口，watermark如何只触发所在的组，而不触发所有的组

[Utopia]

Hi,

Flink 的水印在同一个算子上都是一样的，所以每个 keyed stream 共享的是一个水印，不能分别触发器。

Best  regards
Utopia
在 2020年3月6日 +0800 17:10，小旋锋 <whir...@qq.com>，写道：
> 大家好：
> &nbsp; &nbsp; &nbsp; &nbsp; 数据流经过 keyby 分组后，在分别进入滚动窗口：
> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;sourceDataStream .keyBy(id) 
> .window(TumblingEventTimeWindows.of(Time.seconds(10L)))&nbsp;.reduce() 
> .print()
> &nbsp; &nbsp; &nbsp; &nbsp;&nbsp;
> &nbsp; &nbsp; &nbsp; &nbsp; 测试数据：id 从1~1500，每个id由两条数据，每条数据的 
> eventtime是一样的，最后一条是id为1，eventtime大了20秒用来触发窗口计算的数据
> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;实验结果：最后一条用来触发的数据发出后，所有的窗口都计算输出了
> &nbsp; &nbsp; &nbsp;&nbsp;
> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;请问如何配置 最后一条id为1的数据只触发 id=1所在的组的窗口呢？
>
>
> 感谢