style

eason-yuchen-liu · Jun 17, 2024 · 3f266c1 · 3f266c1
1 parent fe9cea1
commit 3f266c1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...n/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala b/...n/scala/org/apache/spark/sql/execution/streaming/state/HDFSBackedStateStoreProvider.scala
@@ -607,8 +607,8 @@ private[sql] class HDFSBackedStateStoreProvider extends StateStoreProvider with
         case None =>
           logWarning(
             log"The state for version ${MDC(LogKeys.FILE_VERSION, startVersion)} doesn't " +
-              log"exist in loadedMaps. Reading snapshot file and delta files if needed..." +
-              log"Note that this is normal for the first batch of starting query.")
+            log"exist in loadedMaps. Reading snapshot file and delta files if needed..." +
+            log"Note that this is normal for the first batch of starting query.")
           loadedMapCacheMissCount.increment()
           readSnapshotFile(startVersion)
       }