即使我没有在flink中处理任何东西,我也需要发射水印吗



我正在从一个流中读取并写入另一个流。我的代码看起来像这个

env.addSource(source).addSink(sink)

我还需要发射水印吗?

不,你没有。只要您没有进行任何使用事件时间的处理,那么您就不需要发出水印。

相关内容

  • 没有找到相关文章

最新更新