pySpark：获取执行者ID

Question

如何在运行pySpark代码时获取执行者ID？我知道使用scala我可以使用SparkEnv.get().executorId()，但是在使用pySpark时我找不到相应的东西。

Answer 1

可以使用REST API查询执行人，我已经用它在pySparkUtils找到executor IPs

波阿斯

Answer 2

星火UI会给你进入到执行程序的ID以及他们的个人表现指标。