我正在评估Flink专门为流式窗口支持生成可能的警报。我关心的是内存使用情况,所以如果有人可以帮助,这将不胜感激。Flink流窗口内存使用
例如,该应用程序将在给定的翻滚窗口(比如说5分钟)内从该流潜在地消耗大量的数据。在评估的时候,如果说有一百万份符合条件的文档,它们是否都会被加载到内存中?
的一般流程是:
producer -> kafka -> flinkkafkaconsumer -> table.window(Tumble.over("5.minutes").select("...").where("...").writeToSink(someKafkaSink)
此外,如果是描述如何内存在这些情况下,我可能忽略的人可以出来,这将是被处理了一些清晰的文档很有帮助。
谢谢
谢谢,你提供的状态后端链接似乎是我正在寻找。 – Sam