如何在Apache Flink中分布式运行时管理内存

Question

我们正在Java 8中构建一个基于Apache Flink的数据流处理应用程序。我们需要维护一个状态填充的对象列表，该列表每隔十秒钟通过源流进行一次特征，该对象每10秒更新。/p>

根据规格，如果可能的话，我们必须使用分布式存储。因此，我的问题是关于Flink的内存管理器：在群集配置中，它是否复制了任务经理使用的内存？还是有任何方法可以使用flink的分布式内存解决方案？

Answer 1

请查看弗林克状态。这样，您可以将其存储在Flink的状态中，该状态将与检查点/保存点等内部机制集成。

如果您需要从其他服务外部查询它，则可以查询状态是一个很好的补充。