我们有一些靠毛线做的活儿。我们想上传flink作业日志到elk，以简化调试/分析。当前flink任务管理器将日志写入 /mnt/flinklogs/$application_id/$container_id . 我们想让它在没有 $applicatoin_id/$container_id 嵌套结构。
我试过了 env.log.dir: /mnt/flink . 使用此设置，无法正确传递配置。
-Dlog.file=/mnt/flinklogs/application_1560449379756_1312/\
container_e02_1560449379756_1312_01_000619/taskmanager.log
1条答案
按热度按时间idv4meu81#
我认为解决这个问题的最佳方法是使用yarn日志聚合将日志写入磁盘，使用elastic文件位将它们发送到elastic。