在使用spark-streaming中需要修改到日志,百度到的答案大部分是通过

ssc.sparkContext.setLogLevel("DEBUG")

来修改日志级别 但是怎么尝试都不生效;我的工程中引入过storm的jar 最终通过追踪代码看到 

org.apache.logging.log4j.core.Logger 引用了storm-core-1.2.3.jar中的log4j2.xml配置文件

通过断点查看context对象可以看到实际引用;那么对应的要修改日志级别只要把log4j2.xml拷贝要工程的resources目录下,就可以正常修改日志级别了

spark-streaming 日志修改问题

 

相关文章: