0°

Flink这个状态是全局的还是 每个并行度一份呀?[阿里云]

Flink这个状态是全局的还是 每个并行度一份呀?

以下为热心网友提供的参考意见

Flink的状态是全局的,而不是每个并行度一份。

以下为热心网友提供的参考意见

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

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====