使用函数COALESCE将null情况转为一个默认值比如0. Kyle Zhang <sherlock0...@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 >
