This is an automated email from the ASF dual-hosted git repository. abhi pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ranger.git
The following commit(s) were added to refs/heads/master by this push: new 8b1d10863 RANGER-5211 : KMS Metric collection thread safety check should not parse config every time (#575) 8b1d10863 is described below commit 8b1d10863488425c7bf87540deb875413a5ff68c Author: Vikas Kumar <talktovikas...@gmail.com> AuthorDate: Thu May 15 12:25:32 2025 +0530 RANGER-5211 : KMS Metric collection thread safety check should not parse config every time (#575) --- .../main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java b/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java index f1880043b..06d865a8a 100755 --- a/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java +++ b/kms/src/main/java/org/apache/hadoop/crypto/key/kms/server/KMSWebApp.java @@ -78,6 +78,7 @@ public class KMSWebApp implements ServletContextListener { private static KeyProviderCryptoExtension keyProviderCryptoExtension; private static KMSMetricsCollector kmsMetricsCollector; + private static boolean isMetricsCollectionThreadsafe; private JmxReporter jmxReporter; public static Configuration getConfiguration() { @@ -133,7 +134,7 @@ public static KMSAudit getKMSAudit() { } public static boolean isMetricCollectionThreadSafe() { - return Boolean.parseBoolean(KMSWebApp.getConfiguration().get(HADOOP_KMS_METRIC_COLLECTION_THREADSAFE, "false")); + return isMetricsCollectionThreadsafe; } public static KMSMetricsCollector getKmsMetricsCollector() { @@ -181,6 +182,7 @@ public void contextInitialized(ServletContextEvent sce) { kmsAudit = new KMSAudit(kmsConf); + isMetricsCollectionThreadsafe = Boolean.valueOf(kmsConf.get(HADOOP_KMS_METRIC_COLLECTION_THREADSAFE, "false")); KMSMetricWrapper kmsMetricWrapper = KMSMetricWrapper.getInstance(isMetricCollectionThreadSafe()); kmsMetricsCollector = kmsMetricWrapper.getKmsMetricsCollector();