fix

apache · Mar 11, 2024 · b11e473 · b11e473
1 parent 423295b
commit b11e473
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/ScanHelper.scala
@@ -21,6 +21,7 @@ package org.apache.paimon.spark
 import org.apache.paimon.CoreOptions
 import org.apache.paimon.io.DataFileMeta
 import org.apache.paimon.table.source.{DataSplit, DeletionFile, RawFile, Split}
+
 import org.apache.spark.sql.SparkSession
 
 import scala.collection.JavaConverters._
@@ -68,7 +69,8 @@ trait ScanHelper {
 
     def closeDataSplit(): Unit = {
       if (currentSplit.nonEmpty && currentDataFiles.nonEmpty) {
-        val newSplit = copyDataSplit(currentSplit.get, currentDataFiles, currentDeletionFiles, currentRawFiles)
+        val newSplit =
+          copyDataSplit(currentSplit.get, currentDataFiles, currentDeletionFiles, currentRawFiles)
         newSplits += newSplit
       }
       currentDataFiles.clear()