指定 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
和一些建议。
我使用的是Flink 1.12,我指定时间特性为事件时间,如下:
env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
忘记指定watermark策略,请问如果只指定TimeCharacteristic,不指定Watermark策略,flink会如何表现
这取决于,如果您不想进行任何基于时间的操作,例如开窗或任何访问记录 timestamp
的操作,那么什么也不会发生,它将正常工作。
如果另一方面你将在这种情况下使用窗口,或者任何其他基于时间的操作,它将抛出 RuntimeException
说记录的时间戳等于 Long.MIN_VALUE
和一些建议。