yarn application mode 提交的flink作业日志怎么加入作业信息 比如yarn Appid等

[tianxy]

为了收集flink作业的日志写入kafka的topic 目前作业采用yarn application mode方式提交 但是日志是没有作业相关信息  这样没法分类分析  所以想着如何给日志每条记录加上 作业的信息  比如 yarn applicationId等。求大神解答！！！