Kyle Zhang Fri, 25 Sep 2020 04:25:08 -0700
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