flink sql中怎么表达窗口的提前触发或延迟触发
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, INTERVAL '10' SECOND) WITH DELAY '1' MINUTE BEFORE WATERMARK"); 报错： Exception in thread "main" org.apache.flink.table.api.SqlParserException:
ERR_ID: SQL-00120001 CAUSE: SQL parse failed: Encountered "WITH" at line 1, column 75. Was expecting one of: "ORDER" ... "LIMIT" ... "OFFSET" ... "FETCH" ... "," ...*来自志愿者整理的flink邮件归档
写回答
-
目前社区的1.9版本的blink-planner在parser层面还不支持，可以通过全局config来配置： table.exec.emit.early-fire.enabled table.exec.emit.early-fire.delay
可以尝试一下。*来自志愿者整理的flink邮件归档
2021-12-08 19:28:14赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
