Re: 答复: flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存

这面还想多请教一下：

我程序中每来一条数据都会去读MapState然后覆盖写入新的时间戳，刚刚发现某一条数据读出了两条一样的时间戳，我推断是第一个线程读出来后还没等覆盖掉，第二个线程又读了一遍，导致出现两条一样的时间戳；


所以想请问flink中MapState是线程安全的吗？



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

回复