pySpark：獲取執行者ID

Question

如何在運行pySpark代碼時獲取執行者ID？我知道使用scala我可以使用SparkEnv.get().executorId()，但是在使用pySpark時我找不到相應的東西。

Answer 1

可以使用REST API查詢執行人，我已經用它在pySparkUtils找到executor IPs

波阿斯

Answer 2

星火UI會給你進入到執行程序的ID以及他們的個人表現指標。