flink log4j2 配置日志输出
在flink代码项目里配置日志级别resources里面创建文件log4j2.xml
代码里log输出
val LOG = LoggerFactory.getLogger(FlinkEvent.getClass) // 这个类填自己的类名
LOG.info("hhhhhhhhhhhh")

flink log4j2 配置日志输出
在flink代码项目里配置日志级别resources里面创建文件log4j2.xml
代码里log输出
val LOG = LoggerFactory.getLogger(FlinkEvent.getClass) // 这个类填自己的类名
LOG.info("hhhhhhhhhhhh")