是线程安全的,mapstate也是keyed state,同一个key的state肯定是同一个线程处理的


| |
熊云昆
|
|
邮箱:[email protected]
|

签名由 网易邮箱大师 定制

在2020年12月07日 18:18,bradyMk 写道:
这面还想多请教一下:

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

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



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

回复