PySpark 中自定义 Log4j Logger（如 LogManager.getLogger("Example Processor")）无法输出 INFO 级别日志，根本原因在于根 Logger 的日志级别（默认或显式设置为 WARN）压制了子 Logger 的更低级别日志；需同步调整根 Logger 级别或确保其不覆盖子 Logger 配置。
pyspark 中自定义 log4j logger（如 `logmanager.getlogger("example processor")`）无法输出 info 级别日志，根本原因在于根 logger 的日志级别（默认或显式设置为 warn）压制了子 logger 的更低级别日志；需同步调整根 logger 级别或确保其不覆盖子 logger 配置。
在 PySpark 应用中，通过 LogManager.getLogger("Example Processor") 创建的自定义 Logger 属于 Log4j 的层次化日志器（hierarchical logger），其实际可输出的日志级别不仅取决于自身 setLevel() 设置，更受限于祖先 Logger（尤其是 root logger）的有效级别。Log4j 的日志传播机制规定：一条日志消息必须同时满足「当前 Logger 级别允许」且「所有祖先 Logger 级别也允许」，才能被最终输出。而 PySpark 默认将 root logger 级别设为 WARN（这也是控制台提示 Setting default log level to "WARN" 的来源），因此即使你为 "Example Processor" 显式设置了 INFO，其 INFO 消息仍会在传播至 root 时被拦截。
✅ 正确配置方式（推荐）
你需要显式提升 root logger 的级别，使其不低于目标子 Logger 的级别（如 INFO 或 DEBUG）：
from pyspark.sql import SparkSession
self.spark = SparkSession.builder \
.master("local[1]") \
.appName("DemoProcessor") \
.getOrCreate()
# 获取 JVM Log4j 类
log4jLogger = self.spark.sparkContext._jvm.org.apache.log4j
# ✅ 关键步骤：设置 root logger 级别为 INFO（或更低）
root_logger = log4jLogger.LogManager.getRootLogger()
root_logger.setLevel(log4jLogger.Level.INFO)
# 创建并配置自定义 Logger
self.log = log4jLogger.LogManager.getLogger("Example Processor")
self.log.setLevel(log4jLogger.Level.INFO) # 可选，但建议保持明确
# 现在 INFO 及以上级别均可正常输出
self.log.info("Info Message!") # ✅ 将可见
self.log.warn("Warn Message!") # ✅
self.log.error("Error Message!") # ✅? 注意：setLevel() 必须在 getLogger() 之后调用，且对 root logger 的设置需早于首次日志输出，否则可能因初始化顺序导致失效。
⚠️ 常见误区与排查要点
- 不要仅依赖 sc.setLogLevel("INFO")：该方法仅控制 Spark 内部组件（如 DAGScheduler、Executor）的日志，不影响用户自定义 Log4j Logger；
- 检查是否重复设置 root 级别：全局或其它模块中若存在 getRootLogger().setLevel(WARN)，会覆盖你的配置；
- 避免使用 DEBUG 作为兜底方案：虽然 DEBUG 能“看到” INFO，但会淹没大量冗余日志，不利于生产环境诊断；
- 确认日志输出目标（Appender）已启用：若 root logger 的 appender（如 ConsoleAppender）被禁用或过滤，仍无法显示——但本例中 WARN/ERROR 可见，说明 appender 正常，问题纯属级别限制。
? 验证是否生效
运行后应看到类似输出：
23/02/09 17:35:01 INFO Example Processor: Info Message! 23/02/09 17:35:01 WARN Example Processor: Warn Message! 23/02/09 17:35:01 ERROR Example Processor: Error Message!
其中 INFO 行出现即表明配置成功。
✅ 总结
PySpark 自定义 Log4j Logger 的日志可见性由最严格祖先级（通常是 root）的日志级别决定。解决 INFO 不输出问题的核心是：显式调用 LogManager.getRootLogger().setLevel(Level.INFO)，确保根日志器不成为瓶颈。这一操作应在 SparkSession 初始化后、首次日志记录前完成，且需避免被后续代码意外覆盖。遵循此原则，即可精准控制各模块日志粒度，兼顾可观测性与性能。
