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

Question

我们正在Java 8中构建一个基于Apache的数据流处理应用程序，我们需要维护一个对象的状态完整列表，这些对象的特性每10秒通过源流更新一次。

根据规范，如果可能的话，我们必须不使用分布式存储。所以，我的问题是关于Flink的内存管理器:在集群配置中，它是否复制任务管理器使用的内存？或者有什么方法可以使用Flink的分布式内存解决方案呢？

Answer 1

请看一下Flink 状态。通过这种方式，您可以将其存储在flink的状态中，这将与检查点/保存点等内部机制集成在一起。

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