diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaVacuumSuite.scala b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaVacuumSuite.scala index 63122d66bd..a4851054a5 100644 --- a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaVacuumSuite.scala +++ b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaVacuumSuite.scala @@ -28,6 +28,7 @@ import org.apache.spark.sql.delta.DeltaTestUtils.createTestAddFile import org.apache.spark.sql.delta.DeltaVacuumSuiteShims._ import org.apache.spark.sql.delta.actions.{AddCDCFile, AddFile, Metadata, RemoveFile} import org.apache.spark.sql.delta.commands.VacuumCommand +import org.apache.spark.sql.delta.coordinatedcommits.CoordinatedCommitsBaseSuite import org.apache.spark.sql.delta.sources.DeltaSQLConf import org.apache.spark.sql.delta.test.DeltaSQLCommandTest import org.apache.spark.sql.delta.test.DeltaSQLTestUtils @@ -56,7 +57,8 @@ trait DeltaVacuumSuiteBase extends QueryTest with GivenWhenThen with DeltaSQLTestUtils with DeletionVectorsTestUtils - with DeltaTestUtilsForTempViews { + with DeltaTestUtilsForTempViews + with CoordinatedCommitsBaseSuite { private def executeWithEnvironment(file: File)(f: (File, ManualClock) => Unit): Unit = { val clock = new ManualClock() @@ -1355,3 +1357,7 @@ class DeltaVacuumSuite timeGapHours = 10 ) } + +class DeltaVacuumWithCoordinatedCommitsBatch100Suite extends DeltaVacuumSuite { + override val coordinatedCommitsBackfillBatchSize: Option[Int] = Some(100) +}