From adc8da402e89ca6c7de26fb109d70a54b8c88fe4 Mon Sep 17 00:00:00 2001
From: Dongjoon Hyun <dongjoon@apache.org>
Date: Mon, 23 Jun 2025 16:50:09 -0700
Subject: [PATCH] [SPARK-52559] Synchronize `SparkOperatorConfManager.getValue`

---
 .../spark/k8s/operator/config/SparkOperatorConfManager.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/spark-operator/src/main/java/org/apache/spark/k8s/operator/config/SparkOperatorConfManager.java b/spark-operator/src/main/java/org/apache/spark/k8s/operator/config/SparkOperatorConfManager.java
index a3e8e369..13e87a9c 100644
--- a/spark-operator/src/main/java/org/apache/spark/k8s/operator/config/SparkOperatorConfManager.java
+++ b/spark-operator/src/main/java/org/apache/spark/k8s/operator/config/SparkOperatorConfManager.java
@@ -60,8 +60,10 @@ protected SparkOperatorConfManager() {
   }
 
   public String getValue(String key) {
-    String currentValue = configOverrides.getProperty(key);
-    return StringUtils.isEmpty(currentValue) ? getInitialValue(key) : currentValue;
+    synchronized (this) {
+      String currentValue = configOverrides.getProperty(key);
+      return StringUtils.isEmpty(currentValue) ? getInitialValue(key) : currentValue;
+    }
   }
 
   public String getInitialValue(String key) {