apache-flink - 在 Flink 状态查询中，查询的结果是读未提交还是读提交

Question

这篇论文说

可查询状态的当前实现支持通过键点查找值。查询客户端向 Flink master (JobManager) 询问持有查询 key 的 state 分区的 operator 实例的位置。然后，客户端向相应的 TaskManager 发送请求，该 TaskManager 从状态后端检索当前为该键保存的值。从传统的数据库隔离级别来看，查询访问未提交状态，因此遵循未提交读隔离级别。作为未来的工作，我们计划通过让 TaskManagers 保持已提交快照的状态，并使用该状态来回答临时查询来添加已提交读隔离支持。

最新版本的 Flink 中是否已经实现了带有已提交读隔离级别的状态查询。

标签： apache-flinkstate-management

Answer 1

不，这没有改变。使用可查询状态，您可以访问处理查询时发生的任何状态。

这意味着，例如，后续恢复可能会有效地将状态回滚到较早的值。