You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by Kyle Zhang <sh...@gmail.com> on 2020/09/25 11:23:50 UTC

关于sql中null值设置watermark

Hi，
    我在flink1.11 create ddl中使用 WATERMARK FOR wm AS wm - INTERVAL '5’ SECOND
设置watermark，当有脏数据的时候wm为null，就会报RowTime field should not be null, please
convert it to a non-null long value.有没有好的方法直接忽略脏数据。

Best

Re: 关于sql中null值设置watermark

Posted by 赵一旦 <hi...@gmail.com>.

使用函数COALESCE将null情况转为一个默认值比如0.

Kyle Zhang <sh...@gmail.com> 于2020年9月25日周五 下午7:24写道：

> Hi，
>     我在flink1.11 create ddl中使用 WATERMARK FOR wm AS wm - INTERVAL '5’ SECOND
> 设置watermark，当有脏数据的时候wm为null，就会报RowTime field should not be null, please
> convert it to a non-null long value.有没有好的方法直接忽略脏数据。
>
> Best
>