Hi lec， Window Operator目前是不支持retract的输入的。
lec ssmi <shicheng31...@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: libenc...@gmail.com; libenc...@pku.edu.cn
