我们使用的是ApacheFlink1.9.2，我们已经开始用log4j（flink附带的标准log4j1）以json的形式记录所有内容。当我说json日志时，我的意思是我已经按照 log4j.appender.console.layout.ConversionPattern={"level": "%p", "ts": "%d{ISO8601}", "class": "%c", "line": "%L", "message": "%m"}%n 现在我想在这个json中添加一个字段来指示哪个管道生成了日志。起初，我想我应该添加另一个字段来记录一些环境变量，比如： log4j.appender.console.layout.ConversionPattern={"level": "%p", "ts": "%d{ISO8601}", "class": "%c", "line": "%L", "pipeline: "${PIPELINE}", "message": "%m"}%n ，但这似乎不起作用（是不是因为tm是在管道之前初始化的，而此时占位符已经设置好了？）。
你知道我可以添加当前管道运行的字段的方法吗？在“main”中，我可以访问管道名称，也可以访问任务本身中的这个变量。我不希望在日志记录时显式地使用这个变量，但是在日志记录期间它是自动的。
如果有人有想法，我很乐意听听（如果需要，我们可以使用logback或其他任何东西），
谢谢：）