[SPARK-52559] Synchronize SparkOperatorConfManager.getValue

dongjoon-hyun · dongjoon-hyun · commit adc8da402e89 · 2025-06-23T16:50:09.000-07:00
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
@@ -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) {

Original file line number	Diff line number	Diff line change
`@@ -60,8 +60,10 @@ protected SparkOperatorConfManager() {`
`60`	`60`	`}`
`61`	`61`
`62`	`62`	`public String getValue(String key) {`
`63`		`- String currentValue = configOverrides.getProperty(key);`
`64`		`- return StringUtils.isEmpty(currentValue) ? getInitialValue(key) : currentValue;`
	`63`	`+ synchronized (this) {`
	`64`	`+ String currentValue = configOverrides.getProperty(key);`
	`65`	`+ return StringUtils.isEmpty(currentValue) ? getInitialValue(key) : currentValue;`
	`66`	`+ }`
`65`	`67`	`}`
`66`	`68`
`67`	`69`	`public String getInitialValue(String key) {`