pySpark:获取执行者ID

sal*_*dor 6 apache-spark pyspark

运行pySpark代码时如何获取执行者ID?我知道使用scala可以使用SparkEnv.get().executorId(),但是在使用pySpark时找不到等效项。

Boa*_*har 3

您可以使用REST API来查询执行器,我已在pySparkUtils中使用它来查找执行器 IP

波阿斯