指定 TimeCharacteristic 为 EventTime,但不指定水印策略

Specify TimeCharacteristic to be EventTime, but doens't specify the watermark strategy

我使用的是Flink 1.12,我指定时间特性为事件时间,如下:

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

忘记指定watermark策略,请问如果只指定TimeCharacteristic,不指定Watermark策略,flink会如何表现

这取决于,如果您不想进行任何基于时间的操作,例如开窗或任何访问记录 timestamp 的操作,那么什么也不会发生,它将正常工作。

如果另一方面你将在这种情况下使用窗口,或者任何其他基于时间的操作,它将抛出 RuntimeException 说记录的时间戳等于 Long.MIN_VALUE 和一些建议。