spark運行的時候會產生大量的消息,讓程序的運行結果看起來比較費勁apache
因此能夠再程序中添加一些代碼,設置一下輸出日誌的級別spa
1 import org.apache.log4j.{Level, Logger} 2 3 object Example { 4 Logger.getLogger("org").setLevel(Level.ERROR) 5 6 def main(args: Array[String]) { 7 ...... 8 } 9 }
代碼中Level那裏的參數,能夠設置爲WARN,或者ERROR,這個根據自身需求日誌
直接設置爲ERROR可能會錯過一些比較重要的警告信息,可是這樣輸出的內容也少,能夠直接看到結果code