想问下 flink 设置了watermark, 但我不想数据丢失可以吗。按照常规套路,应该是超过late的就要丢失了。但是假如有时候上游报错,或者kafka问题,或者什么异常问题导致有时一段时间内无法消费,恢复后重新消费,数据全都不丢。有这种做法吗
watermark是用的eventTime,eventTime是数据字段里的时间,不是系统时间,所以如果flink没收到数据,时间是不会走的,不用担心数据丢失
你不用窗口的话,水印跟丢数据就没有关系啊