为什么 spark 中的累加器对工作任务是只写的？

Question

根据累加器的文档：

请注意，工作节点上的任务无法访问累加器的 value()——从这些任务的角度来看，累加器是只写变量。

为什么 spark 为蓄电池提供了这种性质？

Answer 1

累加器不是线程安全的。任务完成后，更新累加器值的 DAG 调度程序在单个线程上执行。因此，如果工作节点具有访问（读取）累加器的值，则读取值可能不一致。这就是为什么我认为它是这样设计的。