0
我正在開發一個監視每個執行程序性能的火花程序,例如當一個執行程序開始工作時以及完成其工作時標記。我正在考慮兩種方式來做到這一點:Spark程序來監視執行程序的性能
首先,開發程序,這樣當執行程序開始工作時,它將當前時間標記爲文件,當它結束時,將該時間標記爲同一文件。最後,除了驅動程序機器之外,所有「日誌」文件都將散佈在整個集羣網絡中。其次,由於執行者會定期向駕駛員報告,每次駕駛員收到來自執行者的消息時,如果消息包含「開始」和「完成」信息,讓駕駛員記錄一切。
這可能嗎?
Spark日誌記錄系統已經做到了這一點。 – Tim
在這裏看到這個東西。 Spark已經有這樣的東西:http://spark.apache.org/docs/latest/monitoring.html –