Hi, 首先,Flink 框架的日志应该不多,不知道具体涉及到 checkpoint 的是哪些 log 呢?(建议以后提问给出尽可能详细的信息,例如使用版本和 log 文件) 1. log 是通过 log4j/logback 等第三方系统控制,conf 文件夹中有相应配置文件,可以调整整体或单个 logger 的 level,建议查阅相关系统资料 2. Flink on YARN 模式下,一般访问 log 是通过 Flink web UI 跳转查看。如果坚持想找到具体 log 文件,Application 结束前在本地文件,可通过 container 进程启动命令看到具体 log 文件,结束后可能归档到 HDFS 上,请查阅 YARN 相关资料 3. log 使用方式,建议阅读官网文档,详见 https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/logging.html,另,Flink 本身不带“日志监控系统”,日志路径详见上述第二个回答
1900 <[email protected]> 于2019年4月4日周四 上午10:45写道: > 程序中设置了检查点,env.enableCheckpointing(5000); > 日志中就不断的有日志,时间长了日志就会越来越大,在yarn控台 看job日志,会越来越大,根本就不能看了 > 1.请问检查点日志打印可以关闭吗?或者有其他方式看吗? > 2.请问在这种模式下,如何去找日志文件存放文件路径,目前找不到,是不是在hdfs中 > 3.请问flink任务中大家是怎么打印日志的?假设slf4j+logback,在on yarn > 模式下如何设置,日志会打到什么地方,能不能被搜集到监控系统中搜集到(日志文件在具体某个路径下,还是在hdfs中)
