設置日誌級別所有執行者,必須設置它在每個工人在JVM。
例如:
% scala sc.parallelize (Seq (" "))。foreachPartition (x = > {org.apache.log4j進口。{LogManager,水平}進口org.apache.commons.logging.LogFactory LogManager.getRootLogger () .setLevel (Level.DEBUG) val日誌= LogFactory.getLog log.debug (“EXECUTOR-LOG:”)(“開始執行程序調試日誌級別”)})
驗證設置水平,導航到火花UI,選擇執行人選項卡,並打開stderr日誌對於任何遺囑執行人: