Skip to content

Commit 56a48d8

Browse files
committed
Squashed commits:
- 0e54b264f0ad74207f4b47ce9fc79d42698fff81 minor by jackierwzhang <ruowang.zhang@databricks.com> - 2378e77c2c5601c549696c169d3f5f82cc942a75 use union by jackierwzhang <ruowang.zhang@databricks.com> - bf1c0cfd02fbd68d049985624bb5b098317b76ec fix merge conf by jackierwzhang <ruowang.zhang@databricks.com> - a5b353370892c14e4c2da5723fccc41584df4950 Squashed commit of the following: by jackierwzhang <ruowang.zhang@databricks.com> GitOrigin-RevId: 0e54b264f0ad74207f4b47ce9fc79d42698fff81
1 parent f1a1e40 commit 56a48d8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

core/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSource.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -218,7 +218,7 @@ trait DeltaSourceBase extends Source
218218
isStartingVersion: Boolean,
219219
limits: Option[AdmissionLimits] = Some(new AdmissionLimits())):
220220
ClosableIterator[IndexedFile] = {
221-
var iter = if (options.readChangeFeed) {
221+
val iter = if (options.readChangeFeed) {
222222
// In this CDC use case, we need to consider RemoveFile and AddCDCFiles when getting the
223223
// offset.
224224

@@ -242,8 +242,8 @@ trait DeltaSourceBase extends Source
242242
}
243243
}
244244
}
245-
iter = stopIndexedFileIteratorAtSchemaChangeBarrier(iter)
246-
iter
245+
// Stop before any schema change barrier if detected.
246+
stopIndexedFileIteratorAtSchemaChangeBarrier(iter)
247247
}
248248

249249
/**

0 commit comments

Comments
 (0)