diff --git a/core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java b/core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java index 02530cf6c9dd..a4ac5e2ff67a 100644 --- a/core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java +++ b/core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java @@ -54,7 +54,7 @@ public class HadoopFileIO implements HadoopConfigurable, DelegateFileIO { private static final int DEFAULT_DELETE_CORE_MULTIPLE = 4; private static volatile ExecutorService executorService; - private SerializableSupplier hadoopConf; + private volatile SerializableSupplier hadoopConf; private SerializableMap properties = SerializableMap.copyOf(ImmutableMap.of()); /**