答复: flink sql中怎么表达窗口的提前触发或延迟触发

2019-09-11 文章 苏 欣
感谢大佬解答,对于处理窗口迟到数据的话是不是可以通过setIdleStateRetentionTime方法来设置? 发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用 发件人: Benchao Li 发送时间: Wednesday, September 11, 2019 6:38:44 PM 收件人: user-zh@flink.apache.org 主题: Re: flink sql中怎么表达窗口的提前触发或延

Re: flink sql中怎么表达窗口的提前触发或延迟触发

2019-09-11 文章 Benchao Li
目前社区的1.9版本的blink-planner在parser层面还不支持,可以通过全局config来配置: table.exec.emit.early-fire.enabled table.exec.emit.early-fire.delay 可以尝试一下。 苏 欣 于2019年9月11日周三 上午11:45写道: > Blink文档中有介绍到EMIT Strategy,可以用WITH DELAY '1' MINUTE BEFORE WATERMARK或者EMIT > WITHOUT DELAY AFTER WATERMARK等类似的语法来控制窗口触发。 >

flink sql中怎么表达窗口的提前触发或延迟触发

2019-09-10 文章 苏 欣
Blink文档中有介绍到EMIT Strategy,可以用WITH DELAY '1' MINUTE BEFORE WATERMARK或者EMIT WITHOUT DELAY AFTER WATERMARK等类似的语法来控制窗口触发。 但是我使用这种语法作业运行就会报SQL解析错误,请问有没有办法可以在sql中实现控制窗口触发的操作? Table result = tEnv.sqlQuery("select " + "count(*) " + "from dept group by tumble(crt_time,