1. 程式人生 > >Spark應用程式執行日誌檢視

Spark應用程式執行日誌檢視

比如,Spark應用程式程式碼如下:

 defseq(a: Int, b: Int): Int = {

   println("seq: " + a + "\t "+ b)

   math.max(a, b)

 }

 defcomb(a: Int, b: Int): Int = {

   println("comb: " + a + "\t "+ b)

   a + b

  }

   vardata11= sc.parallelize(List((1, 3), (1, 2), (1, 4), (2, 3)))

    data11.aggregateByKey(1)(seq, comb).collect

我要檢視println的日誌的方法:

進入WEBUI頁面:http://192.168.180.156:8085選擇相關的應用程式,在頁面點選表格中Running Applications 的ApplicationID:app-20160520200716-0023

,這時候你可以進入到Spark作業監控的WEB UI介面,比如http://192.168.180.156:8085/app/?appId=app-20160520200716-0023

在頁面中,輸出的日誌有sterr和stdout兩種,在stdout可以檢視程式中輸出的內容。

如果你在程式中使用了println(....)輸出語句,這些資訊會在stdout檔案裡面顯示;其餘的Spark執行日誌會在stderr檔案裡面顯示。

也可以直接進行日誌檔案進行檢視,如:

/home/huangmeiling/lib/spark-1.5.1/work/app-20160520200716-0023/0/stdout

/home/huangmeiling/lib/spark-1.5.1/work/app-20160520200716-0023/0/stderr

例項如下:

點選:stdout


日誌檔案:

轉載請註明出處: