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: