我们正在用Java8构建一个基于ApacheFlink的数据流处理应用程序。我们需要维护一个对象的状态完整列表，这些对象的特征每10秒通过源流更新一次。根据规格，我们必须使用，如果可能的话，没有分布式存储。所以，我的问题是关于flink的内存管理器：在集群配置中，它是否复制任务管理器使用的内存？或者有什么方法可以使用flink的分布式内存解决方案？
qrjkbowd1#
看看Flink州。通过这种方式，您可以将其存储在flink的状态中，该状态将与内部机制（如checkpointing/savepointing等）集成。如果您需要从其他服务外部查询它，可查询状态是一个很好的补充。
1条答案
按热度按时间qrjkbowd1#
看看Flink州。通过这种方式，您可以将其存储在flink的状态中，该状态将与内部机制（如checkpointing/savepointing等）集成。
如果您需要从其他服务外部查询它，可查询状态是一个很好的补充。