关于flink任务的日志收集到kafka，可以在logback配置文件中
我们在做flink的日志收集到kafak时，使用的logback日志配置文件，目前的pattern是%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{60} - %msg，有没有什么办法在里面加入每个job的id，name或者tasknamanger的主机名之类的信息啊。在做ELK的时候，方便查询。 这个配置文件，是整个项目的，是基于Yarn的per job模式，难道每个主类打包的时候，都要改动不同的logbakc配置文件吗？ *来自志愿者整理的flink邮件归档
展开
收起
1
条回答
写回答
写回答
-
我建议可以通env的方式传，在logback或者log4j配置中直接引用相应的env
例如，可以通过如下两个配置传递clusterId到环境变量 containerized.master.env.clusterId=my-flink-cluster containerized.taskmanager.env.clusterId=my-flink-cluster
另外，也有一些内置的环境变量可以来使用 _FLINK_CONTAINER_ID _FLINK_NODE_ID*来自志愿者整理的flink
2021-12-07 20:17:44赞同 展开评论 打赏
问答分类：
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
