apache-flink - 关于 State 和 Flink 有什么好处

Question

让我们假设我有一份工作 max.parallelism=4和一个 RichFlatMapFunction正在与 MapState 合作.创建 MapStateDescriptor 的最佳方式是什么？ ?进RichFlatMapFunction这意味着对于这个类的每个实例，我都会有一个描述符，或者创建一个描述符的实例，例如:public static MapStateDescriptor descriptor在单个类中并从 RichFlatMapFunction 调用它?因为这样做，我将只有一个 MapStateDescriptor而不是 4，还是我误解了什么？
亲切的问候!

Answer 1

几点...

由于您的每一个RichFlatMapFunction子任务可以在不同服务器上的不同 JVM 中运行，它们将如何共享静态 MapStateDescriptor ?

请注意，Flink 的“最大并行度”与默认环境并行度不同。通常，您希望单独保留最大并行度值，并且(如有必要)将您的环境并行度设置为等于集群中的插槽数。

MapStateDescriptor不存储状态。它告诉 Flink 如何创建状态。在您的 RichFlatMapFunction运营商open() call 是你创建状态的地方 使用 状态描述符。

所以 net-net 不用费心使用静态 MapStateDescriptor ，不会有帮助。只需在您的 open() 中创建您的状态(根据许多示例)方法。