spark日志输出级别控制

[参考link]
[参考link]

--conf spark.submit.deployMode=cluster \

import org.apache.log4j.{Level, Logger}

//设置打印ERROR及以上级别的日志
Logger.getLogger("org").setLevel(Level.ERROR)
Logger.getLogger("org.apache.spark").setLevel(Level.ERROR)
Logger.getLogger("org.eclipse.jetty.server").setLevel(Level.ERROR)
spark.sparkContext.setLogLevel("ERROR")

//设置打印FATAL及以上级别的日志
Logger.getLogger("org").setLevel(Level.FATAL)
Logger.getLogger("org.apache.spark").setLevel(Level.FATAL)
Logger.getLogger("org.eclipse.jetty.server").setLevel(Level.FATAL)
spark.sparkContext.setLogLevel("FATAL")

世界终于安静了
peace