From 49d4fdea07f2e1d022c57287d1099e01a94e3023 Mon Sep 17 00:00:00 2001
From: okumin <git@okumin.com>
Date: Sun, 23 Feb 2025 15:39:26 +0900
Subject: [PATCH] Core: Add "volatile" to HadoopFileIO#hadoopConf

---
 core/src/main/java/org/apache/iceberg/hadoop/HadoopFileIO.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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<Configuration> hadoopConf;
+  private volatile SerializableSupplier<Configuration> hadoopConf;
   private SerializableMap<String, String> properties = SerializableMap.copyOf(ImmutableMap.of());
 
   /**