Flink 自身提供的日志查询服务较为有限。若要支持针对业务日志进行更灵活的关键词、键值对(KV)查询、日志统计以及日志告警等操作,可将运行时日志导出至火山日志服务 TLS,从而为 Flink 任务的监控与排障提供更有力的保障。
功能限制
目前仅 Flink 1.16-volcano 以上版本支持 Flink 日志 TLS 导出任务,低版本 Flink 任务不支持导出日志。
操作步骤
- 登录流式计算 Flink 版控制台。
- 在顶部菜单栏选择目标地域。
- 在左侧导航栏选择项目管理,在搜索框中根据项目名称进行模糊搜索,然后单击项目区块进入项目。
- 在项目左侧导航栏选择作业开发 ,然后在目标文件夹内单击目标任务。
- 在任务编辑区域的右侧,从日志配置的弹出抽屉中选择打开日志归档功能。
配置 | 说明 |
---|
根日志级别 | 自定义选择根日志的日志级别。
将会自动全局导出该级别以上的所有日志。为了降低 TLS 的存储成本,可以按需选择导出日志的日志级别。当前支持日志级别如下:TRACE、DEBUG、INFO、WARN、ERROR、FATAL。 |
类日志等级 | 支持按照类模块进行自定义的日志级别设置。
将会按照某个具体的类的日志级别进行导出。优先级是类日志等级 > 根日志等级。 注意:类名必须是类的全路径名,比如 com.bytedance.MyClass
|
TLS 自定义参数 | - topicId:日志写入的目标 Topic。参考日志主题。
- region:TLS 服务的区域。参考 TLS 服务地址。
- accessKeyId:访问 TLS 的访问 Access Key ID。请注意该访问账号需要开通 TLS 写入权限。
- accessKeySecret:访问 TLS 的访问 Access Key 密钥。
- endpoint:TLS 服务的地址。可以参考 TLS 服务地址。
|