Hi Operator state 本身也并不是线程安全的，只是往常的读写都是持有checkpoint锁的task主线程或者checkpoint异步线程，所以才能做到数据安全，SourceFunction文档里面也强调需要在获得checkpointLock的前提下更新state。
至于如何开启Flink中的RocksDB的native metrics，之前给你的文档链接里面有描述，相关的配置项设为true即可。 祝好 唐云 ________________________________ From: bradyMk <[email protected]> Sent: Thursday, December 10, 2020 11:44 To: [email protected] <[email protected]> Subject: Re: 回复：flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存 谢谢大佬解答~最近一直在看相关的知识，我还有两个问题在网上没有找到解答，想咨询一下： 1、如果我不用keyed State，而改用Operator State，Operator State是所有线程操作一个state么？如果这样，那Operator State是线程安全的么？ 2、您之前说的配置 RocksDB 的native metrics，我在官网看到这些指标都是禁用的，那该如何开启呢？我在代码里貌似没有找到相关方法开启各类RocksDB 的native metrics； ----- Best Wishes -- Sent from: http://apache-flink.147419.n8.nabble.com/
