3

是否存在所有并行任务（无论它们在哪个 TM 上运行）都可以写入和读取的真正全局参数？我测试了 GlobalJobParameter 类，但似乎每个线程都维护自己的实例。我正在寻找一个所有 UDF 都可以共享的地方。有人知道吗？非常感谢！

4

1 回答 1

2

GlobalJobParameter是用于配置作业的只读发行版。正如您提到的“读写”，我猜您正在寻找全局共享状态。Flink 不支持这样的东西，因为全局共享状态无法扩展，并且与数据并行的思想相矛盾。

于 2015-08-23T10:21:09.057 回答