diff --git a/connectors/standalone/src/main/scala/io/delta/standalone/internal/SnapshotImpl.scala b/connectors/standalone/src/main/scala/io/delta/standalone/internal/SnapshotImpl.scala index 1e3f0dd4b8..a0697d6c6d 100644 --- a/connectors/standalone/src/main/scala/io/delta/standalone/internal/SnapshotImpl.scala +++ b/connectors/standalone/src/main/scala/io/delta/standalone/internal/SnapshotImpl.scala @@ -83,7 +83,7 @@ private[internal] class SnapshotImpl( import SnapshotImpl._ - private var loadedState = false + @volatile private var loadedState = false private val memoryOptimizedLogReplay = new MemoryOptimizedLogReplay(files, deltaLog.store, hadoopConf, deltaLog.timezone)