背景在Flink中有两种基本的状态:KeyedState和OperatorState,OperatorState很好理解,一个特定的Operator算子共享同一个state,这是实现层面很好做到的。但是KeyedState是怎么实现的?一般来说,正常的人第一眼就会想到:一个task绑定一个KeydState,从网上随便查找资料就能发现正确的答案是:对于每一个Key会绑定一个State,但是这在Flink中是怎么实现的呢?注意:这里我们只讲Flink中是怎么实现一个Key对应一个State的,其他细节并不细说,且state的backend为RocksDB闲说杂谈我们以ValueState类型的K