cmt

delta-io · Apr 13, 2023 · 32e2fee · 32e2fee
1 parent f1a1e40
commit 32e2fee
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSource.scala b/core/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSource.scala
@@ -218,7 +218,7 @@ trait DeltaSourceBase extends Source
       isStartingVersion: Boolean,
       limits: Option[AdmissionLimits] = Some(new AdmissionLimits())):
   ClosableIterator[IndexedFile] = {
-    var iter = if (options.readChangeFeed) {
+    val iter = if (options.readChangeFeed) {
       // In this CDC use case, we need to consider RemoveFile and AddCDCFiles when getting the
       // offset.
 
@@ -242,8 +242,8 @@ trait DeltaSourceBase extends Source
         }
       }
     }
-    iter = stopIndexedFileIteratorAtSchemaChangeBarrier(iter)
-    iter
+    // Stop before any schema change barrier if detected.
+    stopIndexedFileIteratorAtSchemaChangeBarrier(iter)
   }
 
   /**