hi Cayden chen、
也就是说你们日志上报的实现方式是实现自定义appder来实现是吧,这确实是一个不错的方式;
我先前看spark可以实现对应的listener用来实现日志上报,查看了一下flink
api貌似也有对应listen,具体是实现哪一个还不知道,现在我们还处在一个功能整理阶段
Cayden chen <
[hidden email]> 于2020年7月24日周五 上午10:53写道:
> 我们的获取逻辑是通过自定义 logback的appder( flink
> 默认的应该是log4j,对应配置在安装目录的conf下面),appder通过解析当前系统路径(因为flink每个taskmanager会自己定义一个带有applicationId的路径,然后里面会放各种jar包,包括我自定义的appder),获取之后通过MDC.put(),给日志加一列appId,在appder里面把日志上报到外部的日志系统
>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人:
> "user-zh"
> <
>
[hidden email]>;
> 发送时间: 2020年7月24日(星期五) 上午10:49
> 收件人: "user-zh"<
[hidden email]>;
>
> 主题: flink1.11日志上报
>
>
>
> hi、
>
> 我这面想实现一个日志上报的功能,就是flink任务启动后,让flink主动将当前任务日志打到外部存储系统,想问一下flink有对应的接口吗,具体要实现哪一个类哪