From 60397f499a7894bd0bc9654eb15ee9d344685d02 Mon Sep 17 00:00:00 2001 From: Scott Sandre Date: Wed, 4 Sep 2024 12:49:02 -0700 Subject: [PATCH] make loadedState volatile --- .../main/scala/io/delta/standalone/internal/SnapshotImpl.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 1e3f0dd4b8c..a0697d6c6dd 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)