【发布时间】:2020-09-26 05:45:09
【问题描述】:
这个paper,说
可查询状态的当前实现支持通过键点查找值。查询客户端向 Flink master (JobManager) 询问持有查询 key 的 state 分区的 operator 实例的位置。然后,客户端向相应的 TaskManager 发送请求,该 TaskManager 从状态后端检索当前为该键保存的值。从传统的数据库隔离级别来看,查询访问未提交状态,因此遵循未提交读隔离级别。作为未来的工作,我们计划通过让 TaskManager 保持已提交快照的状态,并使用该状态来回答即席查询来添加已提交读隔离支持。
在最新版本的 Flink 中是否已经实现了带有已提交读隔离级别的状态查询。
【问题讨论】:
标签: apache-flink state-management