因此,这里的实际问题相对简单。Python中的每个子进程都从其父级继承其状态:
len(set(sc.parallelize(range(4), 4).map(lambda _: random.getstate()).collect()))# 1
由于父状态没有理由在这种特定情况下更改,并且工作人员的寿命有限,因此每个孩子的状态在每次运行中都将完全相同。

因此,这里的实际问题相对简单。Python中的每个子进程都从其父级继承其状态:
len(set(sc.parallelize(range(4), 4).map(lambda _: random.getstate()).collect()))# 1
由于父状态没有理由在这种特定情况下更改,并且工作人员的寿命有限,因此每个孩子的状态在每次运行中都将完全相同。