Flink-跟着问题读源码:提交作业时未返回yarn applicationId

问题描述

在公司做flink实时计算平台时,需要将flink jar提交到yarn上后获取applicationId,以此来处理后续的状态控制。但是在升级flink1.9.0到flink1.10.1后,突然无法从日志中解析得到applicationId了。

方案

很有意思,最后验证表明,服务端日志和客户端日志可以采用两套日志体系,首先client代码我们公司都是使用logback的,于是,当
1、Server端为logback时,即/lib下的包为logback-classic-1.2.3.jar、logback-core-1.2.3.jar、log4j-over-slf4j-1.7.22.jar时,日志输出会少一些,提交的applicationId未返回
2、Server端为log4j时,即/lib下的包为log4j-1.2.17.jar、slf4j-log4j12-1.7.15.jar时,日志输出正常
3、Server端什么Jar包都不放时,日志输出乱码~


版权声明:本文为wuleidaren原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。