没记错这是一个bug,计算列中含有关键字会异常,可以看下这个issue: https://issues.apache.org/jira/browse/FLINK-16068
Robin Zhang <vincent2015q...@outlook.com> 于2020年12月29日周二 下午6:56写道: > -- 定义时间非系统保留字为事件时间字段,能正常运行 > create table events ( > process_time bigint comment '事件时间', > event string comment '事件类型', > ts AS TO_TIMESTAMP(FROM_UNIXTIME(process_time/1000, 'yyyy-MM-dd > HH:mm:ss')), > WATERMARK FOR ts AS ts - INTERVAL '5' SECOND > ) with ( > ... ... > ); > > 但是,定义的字段是系统保留字时,就会报错: > create table events ( > `time` bigint comment '事件时间', > event string comment '事件类型', > ts AS TO_TIMESTAMP(FROM_UNIXTIME(`time`/1000, 'yyyy-MM-dd HH:mm:ss')), > WATERMARK FOR ts AS ts - INTERVAL '5' SECOND > ) with ( > ... ... > ); > > 但现在问题是:神策埋点的事件时间字段是time,如果单独写一个程序转换字段的话,显得有些鸡肋。 > 不知道是不是bug,目前还没想到较好的解决方案。 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >