From 0e328bf930d4f7e39a8901c8960275eb28c35ff2 Mon Sep 17 00:00:00 2001 From: Archit Goyal Date: Tue, 25 Aug 2026 22:50:19 -0700 Subject: [PATCH] Log effective HistoryServer configuration at startup Adds storage type, load mode, and retention settings to the startup log. --- .../runtime/webmonitor/history/HistoryServer.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java index 151fd43b8233f3..5f993d7ba8d895 100644 --- a/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java +++ b/flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java @@ -261,6 +261,19 @@ public HistoryServer( archiveLoadMode = config.get(HistoryServerOptions.HISTORY_SERVER_ARCHIVE_LOAD_MODE); HistoryServerOptions.HistoryServerArchiveStorageType archiveStorageType = config.get(HistoryServerOptions.HISTORY_SERVER_ARCHIVE_STORAGE_TYPE); + LOG.info( + "HistoryServer effective configuration: storage-type={}, load-mode={}, " + + "retained-jobs={}, retained-applications={}, retained-ttl={}, " + + "clean-expired-jobs={}, clean-expired-applications={}.", + archiveStorageType, + archiveLoadMode, + config.get(HistoryServerOptions.HISTORY_SERVER_RETAINED_JOBS), + config.get(HistoryServerOptions.HISTORY_SERVER_RETAINED_APPLICATIONS), + config.getOptional(HistoryServerOptions.HISTORY_SERVER_RETAINED_TTL) + .map(Object::toString) + .orElse("unset"), + cleanupExpiredJobs, + cleanupExpiredApplications); AbstractHistoryServerHandler.HistoryServerHandlerFactory historyServerHandlerFactory; switch (archiveStorageType) { case FILE: