关于Flink中AssignerWithPeriodicWatermarks定时生成Watermark的问题

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

阅读 2.7k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进