我这边有个程序,已经进行了如下设置,即使用EventTimestreamEnv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);
当我用AscendingTimestampExtractor(实现了AssignerWithPeriodWatermarks)后,也就是定期产生WaterMark。然后用下面的代码把定期周期设置得非常大,以至于让它不执行。streamEnv.getConfig().setAutoWatermarkInterval(999999999999999999L);
按照我的理解是WaterMark应该就不会更新了才对,可是跑起来和默认的是一样的结果,我就搞不懂了,求大神指教:-O