回复：关于FlinkSQL的窗口和触发

Tue, 01 Sep 2020 02:31:21 -0700 

Hi:
可以试试增加如下配置：
table.exec.emit.early-fire.enabled = true
  table.exec.emit.early-fire.delay = 10000


Best,
Xiao


 原始邮件 
发件人: Cayden chen<1193216...@qq.com>
收件人: user-zh<user-zh@flink.apache.org>
发送时间: 2020年9月1日(周二) 17:10
主题: 回复：关于FlinkSQL的窗口和触发


hi，目前不支持。sql语义只支持窗口结束触发计算 ------------------&nbsp;原始邮件&nbsp;------------------ 
发件人: "user-zh" <haibin...@163.com&gt;; 发送时间:&nbsp;2020年9月1日(星期二) 中午1:43 
收件人:&nbsp;"user-zh@flink.apache.org"<user-zh@flink.apache.org&gt;; 
主题:&nbsp;关于FlinkSQL的窗口和触发 Hi all， 在FlinkSQL中，我知道可以通过group by 
window去做窗口处理，但是如果触发时间和窗口时间不一致，如何去表达呢？ 
比如说，统计一天的PV和UV，每隔10S更新数据，在StreamingApi里面，可以通过timeWindow(1Day) + 
trigger(10Seconds)去实现，但是到FlinkSQL上要如何实现呢？ 感激不尽。 | | BenChen | | 
haibin...@163.com | 签名由网易邮箱大师定制

回复