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 <[email protected]>
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();