Flink sql 1.10.1 GroupbyWindow错误记录

  • Post author:
  • Post category:其他




错误如下:

在这里插入图片描述



正确如下:

在这里插入图片描述



为何这样??

Flink SQL引入了计算列(computed column)的概念,其语法为column_name AS computed_column_expression,它的作用是在表中产生数据源schema不存在的列,并且可以利用原有的列、各种运算符及内置函数。比如在以上SQL语句中,就利用内置的PROCTIME()函数生成了处理时间列,并利用原有的ts字段与FROM_UNIXTIME()、TO_TIMESTAMP()两个时间转换函数生成了事件时间列。

为什么canalTimeStamp字段不能直接用作事件时间呢?因为Flink SQL规定***时间特征必须是TIMESTAMP(3)类型***,即形如”yyyy-MM-ddTHH:mm:ssZ”格式的字符串,Unix时间戳自然是不行的,所以要先转换一波。

既然有了事件时间,那么自然要有水印。



版权声明:本文为weixin_45480444原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。