Flink版本:1.11.1

 

官网文档中定义如下:

<computed_column_definition>:

  column_name AS computed_column_expression [COMMENT column_comment]

我看到官方文档中计算列是可以指定column_comment的,但我尝试了一下发现会报错

 

使用方式和报错信息如下:

create table t1( 

       data_time STRING, 

       row1_time AS to_timestamp(data_time) COMMENT 'test'

       WATERMARK FOR row1_time AS row1_time - INTERVAL '5' SECOND

) with(...)

 

org.apache.flink.sql.parser.impl.ParseException: Encountered "COMMENT" at
line 1, column 74.

Was expecting one of:

    "FILTER" ...

    "OVER" ...

    "WITHIN" ...

    ")" ...

    "," ...

    "." ...

    "NOT" ...

    "IN" ...

    "<" ...

    "<=" ...

    ">" ...

    ">=" ...

    "=" ...

    "<>" ...

    "!=" ...

    "BETWEEN" ...

    "LIKE" ...

    "SIMILAR" ...

    "+" ...

    "-" ...

    "*" ...

    "/" ...

    "%" ...

    "||" ...

    "AND" ...

    "OR" ...

    "IS" ...

    "MEMBER" ...

    "SUBMULTISET" ...

    "CONTAINS" ...

    "OVERLAPS" ...

    "EQUALS" ...

    "PRECEDES" ...

    "SUCCEEDS" ...

    "IMMEDIATELY" ...

    "MULTISET" ...

    "[" ...

    "FORMAT" ...

    "IGNORE" ...

    "RESPECT" ...

    

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.generateParseException(F
linkSqlParserImpl.java:36086)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.jj_consume_token(FlinkSq
lParserImpl.java:35900)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreateTable(FlinkSqlP
arserImpl.java:5271)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreateExtended(FlinkS
qlParserImpl.java:6269)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlCreate(FlinkSqlParser
Impl.java:19047)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmt(FlinkSqlParserIm
pl.java:3308)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.SqlStmtList(FlinkSqlPars
erImpl.java:2775)

       at
org.apache.flink.sql.parser.impl.FlinkSqlParserImpl.parseSqlStmtList(FlinkSq
lParserImpl.java:252)

       at
org.apache.calcite.sql.parser.SqlParser.parseStmtList(SqlParser.java:201)

回复