Flink报Record has Long.MIN_VALUE timestamp错误如何解决？

Record has Long.MIN_VALUE timestamp (= no timestamp marker). Is the time characteristic set to 'ProcessingTime'

该报错是Flink EventTime语义下的常见校验错误，触发条件如下：

• Flink的EventTime语义要求所有参与时间类计算（比如EventTime窗口、定时器等）的每条数据，都必须绑定一个从业务数据中提取的事件时间戳，若未分配该时间戳，数据的默认时间戳为Long.MIN_VALUE
• 当你使用了TumblingEventTimeWindows这类EventTime专属算子时，Flink会自动校验流入数据的时间戳，只要检测到存在Long.MIN_VALUE的无效时间戳就会抛出该报错。通常有两种场景会导致该问题：
  1. 未显式设置作业的时间特性为EventTime，默认使用ProcessingTime语义，但是却调用了EventTime类算子
  2. 已经设置了EventTime时间特性，但没有为数据流分配时间戳和水印，所有数据的事件时间还是默认的无效值

你做的两处修改分别对应解决了上述两个触发条件的问题：

1. env.setTimeCharacteristic(TimeCharacteristic.EventTime)的作用 #

该配置是全局声明作业使用事件时间语义，后续所有时间相关算子都会优先读取数据绑定的事件时间戳做计算，而非使用Flink节点本地的处理时间，匹配你使用的EventTime窗口算子的要求。

2. assignTimestampAndWatermarks方法的作用 #

你使用的forBoundedOutOfOrderness水印策略会完成两个核心动作：

• 遍历每条流入的Event数据，按照规则提取业务时间字段，为每条数据绑定合法的事件时间戳，替换默认的Long.MIN_VALUE无效值，通过Flink的时间戳校验
• 按照你设置的20秒乱序容忍度周期性生成水印，水印用于推进EventTime窗口的计算进度：当水印超过某个窗口的结束时间时，Flink就会触发该窗口的计算逻辑，20秒的配置代表允许数据最多迟到20秒，超过该阈值的晚到数据会被默认丢弃。

两处配置配合后，EventTime窗口可以正常读取每条数据的时间戳完成窗口分配和计算，不再触发无效时间戳的校验报错。

内容的提问来源于stack exchange，提问作者shanker861