这个纸,说
queryable状态的当前实现支持按键查找值。查询客户端向Flink主(JobManager)请求保存查询密钥状态分区的操作符实例的位置。然后,客户端向相应的TaskManager发送一个请求,该请求从状态后端检索当前为该键保存的值。从传统的数据库隔离级别角度来看,查询访问未提交状态,从而遵循读未提交隔离级别。作为未来的工作,我们计划通过让TaskManagers保持提交快照的状态来添加读提交的隔离支持,并使用该状态来回答特殊的查询。
是否在最新版本Flink中实现了使用读提交的隔离级别进行状态查询。
发布于 2020-09-26 10:05:30
不,这一点没有改变。使用queryable状态,您将访问查询处理时发生的任何状态。
这意味着,例如,后续的恢复可能有效地将状态回滚到较早的值。
https://stackoverflow.com/questions/64074302
复制相似问题