flink cep sql 使用动态窗口的问题

动态窗口格式：INTERVAL intervalExpression。例如：INTERVAL A.windowTime + 10，其中A为PATTERN定义中第一个patternVariable。

版本是1.12 当我使用    PATTERN (A{5,} B)   WITHIN INTERVAL '30' SECOND 一切是正常的

于是改成动态窗口格式     PATTERN (A{5,} B) WITHIN INTERVAL A.`timestamp` + 10 的时候报错

Exception in thread "main" org.apache.flink.table.api.SqlParserException: SQL parse failed. Encountered "A" at line 1, column 409.
Was expecting one of:
    <QUOTED_STRING> ...
    "+" ...
    "-" ...
    
    at org.apache.flink.table.planner.calcite.CalciteParser.parse(CalciteParser.java:56)
    at org.apache.flink.table.planner.delegation.ParserImpl.parse(ParserImpl.java:76)
    at org.apache.flink.table.api.internal.TableEnvironmentImpl.sqlQuery(TableEnvironmentImpl.java:639)

 

不知掉具体该如何使用，求大佬们指教

不知道你这个问题是否已经解决, 如果还没有解决的话:

• 这篇文章：Flink 实时计算 -- 1.9 SQL使用注意点 也许能够解决你的问题，你可以看下

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 以帮助更多的人 ^-^