nit

zikangh · zikangh · commit a0fa2dbda3ea · 2025-10-31T22:42:33.000Z
diff --git a/spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSource.scala b/spark/src/main/scala/org/apache/spark/sql/delta/sources/DeltaSource.scala
@@ -1280,7 +1280,6 @@ case class DeltaSource(
   override def toString(): String = s"DeltaSource[${deltaLog.dataPath}]"
 
   trait DeltaSourceAdmissionBase { self: AdmissionLimits =>
-
     // This variable indicates whether a commit has already been processed by a batch or not.
     var commitProcessedInBatch = false
 
@@ -1337,6 +1336,7 @@ case class DeltaSource(
     def hasCapacity: Boolean = {
       filesToTake > 0 && bytesToTake > 0
     }
+
   }
 
   /**

Original file line number	Diff line number	Diff line change
`@@ -1280,7 +1280,6 @@ case class DeltaSource(`
`1280`	`1280`	`override def toString(): String = s"DeltaSource[${deltaLog.dataPath}]"`
`1281`	`1281`
`1282`	`1282`	`trait DeltaSourceAdmissionBase { self: AdmissionLimits =>`
`1283`		`-`
`1284`	`1283`	`// This variable indicates whether a commit has already been processed by a batch or not.`
`1285`	`1284`	`var commitProcessedInBatch = false`
`1286`	`1285`
`@@ -1337,6 +1336,7 @@ case class DeltaSource(`
`1337`	`1336`	`def hasCapacity: Boolean = {`
`1338`	`1337`	`filesToTake > 0 && bytesToTake > 0`
`1339`	`1338`	`}`
	`1339`	`+`
`1340`	`1340`	`}`
`1341`	`1341`
`1342`	`1342`	`/**`