Flink这个状态是全局的还是 每个并行度一份呀?
以下为热心网友提供的参考意见
Flink的状态是全局的,而不是每个并行度一份。
以下为热心网友提供的参考意见
确保MapState的key选择正确,并且对于每个并行度而言都是唯一的。如果您使用的是唯一的键,则MapState中的所有副本都将具有相同的键,因此可以执行维表关联。
需要确保MapState的数据存储在磁盘上,而不是内存中。如果您的数据存储在内存中,则在处理大量数据时可能会出现内存不足的问题。
可以使用Flink提供的数据读取和写入工具,例如DataStreamReader和DataStreamWriter,来读取和写入MapState中的数据。
—来自实时计算 Flink版文档和个人解析