flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Benchao Li <libenc...@gmail.com>
Subject Re: 关于撤回流的Watermark问题
Date Tue, 28 Apr 2020 02:19:16 GMT
Hi lec,

Window Operator目前是不支持retract的输入的。

lec ssmi <shicheng31604@gmail.com> 于2020年4月28日周二 上午9:45写道:

> Hi:
>    在tableAPI中,带有时间属性的聚合,比如window聚合,对于retract消息的事件延迟怎么处理呢?
>    举个例子,
>    假设上游使用了last_value 操作加over window操作,一直生成一条数据的最新值,然后和另外一个流做join
, 再进行 time
>
> window聚合操作。现在已经十点,最大延迟为一个小时,这个时候event-time为9点的消息,已经超过了最大延迟,但是在join中仍然生成一条join后的记录(因为join不过滤超时的数据),这条记录会对原先join好的一条记录进行撤回。那这个撤回消息,在到达time
> window的时候,因为超过了最大延迟,DELELE记录和INSERT记录都不会被处理吗?
>  谢谢。
>


-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: libenchao@gmail.com; libenchao@pku.edu.cn
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message