我想确切地知道
-
何时将水印值设置为
Long.MaxValue？(关于取消SourceFunction？通过cli&web面板取消作业？…( -
它对应用程序意味着什么？(作业结束？作业失败？没有重新启动？(
-
应该如何处理？(清除所有状态？计时器呢？正如我所看到的，在这种状态下注册一个新的计时器将使应用程序永远运行！如果我能够在最后一个水印中保持一个状态，以便在以后的时间/运行中从中恢复，我应该如何保持计时器状态？(
最后一个水印是在SourceFunction退出run方法时发出的，这意味着您已经消耗了所有输入。
考虑到这一点，您不应该需要清除，因为一旦水印到达所有接收器，作业就会被标记为完成。