sal*_*dor 6 apache-spark pyspark
运行pySpark代码时如何获取执行者ID?我知道使用scala可以使用SparkEnv.get().executorId(),但是在使用pySpark时找不到等效项。
SparkEnv.get().executorId()
Boa*_*har 3
您可以使用REST API来查询执行器,我已在pySparkUtils中使用它来查找执行器 IP
波阿斯
归档时间:
8 年,6 月 前
查看次数:
1218 次
最近记录:
8 年,4 月 前