在flink状态查询中,查询结果是read uncommitted还是read committed

brtdzjyr  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(389)

这家报纸说
可查询状态的当前实现支持按键点查找值。查询客户机向flink主机(jobmanager)询问持有查询密钥的状态分区的操作符示例的位置。然后,客户机向相应的taskmanager发送一个请求,taskmanager从state后端检索当前为该键保留的值。从传统的数据库隔离级别来看,查询访问未提交状态,因此遵循读未提交隔离级别。作为未来的工作,我们计划通过让TaskManager保持提交快照的状态来添加读取提交隔离支持,并使用该状态来回答临时查询。
在最新版本的flink中是否实现了读取提交隔离级别的状态查询。

lmyy7pcs

lmyy7pcs1#

不,这没有改变。使用queryable state,您可以访问处理查询时的任何状态。
这意味着,例如,后续恢复可能会有效地将状态回滚到较早的值。

相关问题