大家好! 使用flink1.11 sql接入kafka ,format为csv 从eventTime字段中抽取事件时间 rowtime AS TO_TIMESTAMP(FROM_UNIXTIME(eventTime / 1000, 'yyyy-MM-dd HH:mm:ss')) eventTime可能存在脏数据(非13位的毫秒时间戳),设置了 'csv.ignore-parse-errors' = 'true', 那么eventTime会被设置为null,此时会报一个异常: Caused by: java.lang.RuntimeException: RowTime field should not be null, please convert it to a non-null long value.
有没有什么好的方式可以解决 祝好! 18500348...@163.com