State本身不是线程安全的 
[1],但是目前对于state的更新都是在task主线程内,而task主线程是线程安全的。除非通过一些特别的方式,例如异步的metrics线程用户逻辑下访问state导致的state写更新副作用,一般是不会出现写错的问题。

[1] https://issues.apache.org/jira/browse/FLINK-13072

祝好
唐云
________________________________
From: bradyMk <zhbm...@126.com>
Sent: Tuesday, December 8, 2020 17:59
To: user-zh@flink.apache.org <user-zh@flink.apache.org>
Subject: Re: 回复:flink使用RocksDB增量checkpoints,程序运行一段时间报出:超出物理内存

好的,谢谢大佬解答~



-----
Best Wishes
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复