apache-flink - Flink Logger nullPointException

Question

我想用logFlink 代码编写。因此，我将这些行添加到conf/log4j.properties：

log4j.logger.myLogger=DEBUG, FILE
log4j.appender.FILE=org.apache.log4j.DailyRollingFileAppender
log4j.appender.FILE.File=myLog.out
log4j.appender.FILE.ImmediateFlush=true
log4j.appender.FILE.Threshold=debug
log4j.appender.FILE.Append=true
log4j.appender.FILE.DatePattern='.' yyyy-MM-dd-HH-mm
log4j.appender.FILE.layout=org.apache.log4j.PatternLayout
log4j.appender.myLogger.layout.conversionPattern=%d %-5p %c - %m%n

然后，我在我的地图类中获取记录器实例，如下所示：

private transient Logger logger = LoggerFactory.getLogger("FILE");

或者

private transient Logger logger = LoggerFactory.getLogger(MapClass.class);

但是，nullPointException当我使用记录器实例时，我得到了。

请您指导我有什么问题吗？

先感谢您。

标签： apache-flinkflink-streaming

Answer 1

您的记录器被标记为瞬态，因此在序列化后它为空。

您要么必须在 RichMapFunction 的 open() 方法中对其进行初始化，要么将其设为静态。