flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Utopia <gejunwei...@gmail.com>
Subject Re: keyby后滚动窗口,watermark如何只触发所在的组,而不触发所有的组
Date Fri, 06 Mar 2020 09:20:39 GMT
Hi,

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

Best  regards
Utopia
在 2020年3月6日 +0800 17:10,小旋锋 <whirlys@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所在的组的窗口呢?
>
>
> 感谢

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message