This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new dcb63992ff2 [FLINK-40478][runtime-web] Log effective HistoryServer
configuration at startup (#29020)
dcb63992ff2 is described below
commit dcb63992ff22e33b270c2897180f15b2670bbdaf
Author: Archit Goyal <[email protected]>
AuthorDate: Thu Sep 10 03:23:13 2026 -0700
[FLINK-40478][runtime-web] Log effective HistoryServer configuration at
startup (#29020)
* Log effective HistoryServer configuration at startup
Adds storage type, load mode, and retention settings to the startup log.
* Update
flink-runtime-web/src/main/java/org/apache/flink/runtime/webmonitor/history/HistoryServer.java
Co-authored-by: Purushottam Sinha <[email protected]>
---------
Co-authored-by: Purushottam Sinha <[email protected]>
---
.../flink/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 151fd43b823..94cc0518019 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 class 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:
