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

Tue, 10 Sep 2019 20:45:36 -0700 

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:
         <EOF>
         "ORDER" ...
         "LIMIT" ...
         "OFFSET" ...
         "FETCH" ...
         "," ...

发送自 Windows 10 版邮件<https://go.microsoft.com/fwlink/?LinkId=550986>应用

回复