在 Flink on YARN 中，你可以通过以下参数来控制历史日志的保留和清理行为：
yarn.log-aggregation-enable：指定是否启用日志聚合功能，默认值为 true。如果设置为 false，则 Flink 不会将日志发送到 HDFS 中的聚合目录。
yarn.log-aggregation.retain-seconds：指定历史日志的保留时间（以秒为单位），默认值为 3,600 秒（1 小时）。如果设置为 0，则表示不保留历史日志。在指定时间内，Flink 会将任务运行日志保存在 HDFS 中的聚合目录中。
yarn.log-aggregation.retain-check-interval-seconds：指定检查历史日志保留时间间隔（以秒为单位），默认值为 300 秒（5 分钟）。Flink 会每隔一定时间检查一次历史日志的保留时间，并删除已过期的日志文件。
你可以在 flink-conf.yaml 文件中设置这些参数，例如：
yarn.log-aggregation-enable: true yarn.log-aggregation.retain-seconds: 3600 在此配置中，Flink on YARN 将启用日志聚合功能，并将任务运行日志保留 1 小时。每隔 5 分钟检查一次历史日志的保留时间，并删除已过期的日志文件。
注意，这些参数只控制历史日志的保留和清理行为。如果你想要减少 Flink 程序的运行日志量，可以通过修改 log4j.properties 文件中的日志级别来调整日志输出水平。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请联系我们，一经查实，本站将立刻删除。
如需转载请保留出处：https://51itzy.com/kjqy/190793.html