这家报纸说
可查询状态的当前实现支持按键点查找值。查询客户机向flink主机(jobmanager)询问持有查询密钥的状态分区的操作符示例的位置。然后,客户机向相应的taskmanager发送一个请求,taskmanager从state后端检索当前为该键保留的值。从传统的数据库隔离级别来看,查询访问未提交状态,因此遵循读未提交隔离级别。作为未来的工作,我们计划通过让TaskManager保持提交快照的状态来添加读取提交隔离支持,并使用该状态来回答临时查询。
在最新版本的flink中是否实现了读取提交隔离级别的状态查询。
1条答案
按热度按时间lmyy7pcs1#
不,这没有改变。使用queryable state,您可以访问处理查询时的任何状态。
这意味着,例如,后续恢复可能会有效地将状态回滚到较早的值。