开发者社区> 问答> 正文

FlinkSQL 1.10 事件时间声明不能包含系统保留字

-- 定义时间非系统保留字为事件时间字段,能正常运行  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,目前还没想到较好的解决方案。*来自志愿者整理的flink邮件归档

展开
收起
CCCC 2021-12-02 15:03:47 671 0
1 条回答
写回答
取消 提交回答
  • 没记错这是一个bug,计算列中含有关键字会异常,可以看下这个issue:

    https://issues.apache.org/jira/browse/FLINK-16068*来自志愿者整理的FLINK邮件归档

    2021-12-02 15:56:05
    赞同 展开评论 打赏
问答分类:
问答标签:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载