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) {