OK. done。 成功了。 至于怎么区分机器的话可以使用env或sys变量。
JM和TM的话可以自己改一改flink-daemon.sh脚本的启动部分，新增 "-Dxxx=${DAEMON}-${id}"
系统启动属性。然后log4使用${sys:xxx}
yidan zhao <hinobl...@gmail.com> 于2021年6月10日周四 下午8:08写道：
>
> 我也尝试了一波，不过比较奇怪的是，我程序测试log4可以写kafka OK。但是flink就是写不进去。
>
> yidan zhao <hinobl...@gmail.com> 于2021年6月10日周四 下午4:18写道：
> >
> > @yujianbo hi。可以把你log4j的配置发出来嘛，我也参考参考。
> >
> > yujianbo <15205029...@163.com> 于2021年6月10日周四 下午3:31写道：
> > >
> > > 大佬，能告知一下吗？我目前知道lay out有这么多的参数可以配置，哪个参数能区分jm或者tm的日志呢：
> > >
> > > 具体的格式化说明：
> > > %p：输出日志信息的优先级，即DEBUG，INFO，WARN，ERROR，FATAL。
> > > %d：输出日志时间点的日期或时间，默认格式为ISO8601，也可以在其后指定格式，如：%d{yyyy/MM/dd
> > > HH:mm:ss,SSS}。
> > > %r：输出自应用程序启动到输出该log信息耗费的毫秒数。
> > > %t：输出产生该日志事件的线程名。
> > >
> > > %l：输出日志事件的发生位置，相当于%c.%M(%F:%L)的组合，包括类全名、方法、文件名以及在代码中的行数。例如：test.TestLog4j.main(TestLog4j.java:10)。
> > > %c：输出日志信息所属的日志对象，也就是getLogger（）中的内容。
> > > %C：输出日志信息所属的类目；
> > > %logger：log4j中没有此格式；
> > > %M：输出产生日志信息的方法名。
> > > %F：输出日志消息产生时所在的文件名称。
> > > %L:：输出代码中的行号。
> > > %m:：输出代码中指定的具体日志信息。
> > > %n：输出一个回车换行符，Windows平台为"rn"，Unix平台为"n"。
> > > %x：输出和当前线程相关联的NDC(嵌套诊断环境)，尤其用到像java servlets这样的多客户多线程的应用中。
> > > %%：输出一个"%"字符。
> > >
> > >
> > >
> > > --
> > > Sent from: http://apache-flink.147419.n8.nabble.com/
