Flink Streaming 有真正的全局参数吗?
Is There Real Global Parameters in Flink Streaming?
是否存在所有并行任务(无论它们 运行 在哪个 TM 上)都可以写入和读取的真实全局参数?我测试了 GlobalJobParameter Class,但似乎每个线程都维护自己的实例。我正在寻找所有 UDF 都可以共享的地方。有人知道吗?非常感谢!
GlobalJobParameter
是配置作业的只读分布。正如您提到的“write and read”,我猜您正在寻找全局共享状态。 Flink 不支持这样的东西,因为全局共享状态 无法扩展 ,并且与数据并行性的想法相矛盾。
是否存在所有并行任务(无论它们 运行 在哪个 TM 上)都可以写入和读取的真实全局参数?我测试了 GlobalJobParameter Class,但似乎每个线程都维护自己的实例。我正在寻找所有 UDF 都可以共享的地方。有人知道吗?非常感谢!
GlobalJobParameter
是配置作业的只读分布。正如您提到的“write and read”,我猜您正在寻找全局共享状态。 Flink 不支持这样的东西,因为全局共享状态 无法扩展 ,并且与数据并行性的想法相矛盾。