将 TimeCharacteristic 指定为 EventTime，但不指定水印策略

Question

我使用的是Flink 1.12，我已经将时间特性指定为事件时间，如下所示：

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)

我忘记指定水印策略了，我想问一下，如果我只指定TimeCharacteristic，而不指定水印策略，flink会怎么做。

Answer 1

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

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