diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuite.scala b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuite.scala
index 86757491fa7..b28b68bb67a 100644
--- a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuite.scala
+++ b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuite.scala
@@ -48,6 +48,14 @@ class DeltaRetentionSuite extends QueryTest
     getDeltaFiles(dir) ++ getUnbackfilledDeltaFiles(dir) ++ getCheckpointFiles(dir)++
       getCrcFiles(dir)
 
+  test("startTxnWithManualLogCleanup") {
+    withTempDir { tempDir =>
+      val log = DeltaLog.forTable(spark, new Path(tempDir.getCanonicalPath))
+      startTxnWithManualLogCleanup(log).commit(Nil, testOp)
+      assert(!log.enableExpiredLogCleanup())
+    }
+  }
+
   test("delete expired logs") {
     withTempDir { tempDir =>
       val startTime = getStartTimeForRetentionTest
diff --git a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuiteBase.scala b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuiteBase.scala
index 2e1c79137e5..304d8365394 100644
--- a/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuiteBase.scala
+++ b/spark/src/test/scala/org/apache/spark/sql/delta/DeltaRetentionSuiteBase.scala
@@ -298,12 +298,4 @@ trait DeltaRetentionSuiteBase extends QueryTest
     txn.updateMetadata(Metadata())
     txn
   }
-
-  test("startTxnWithManualLogCleanup") {
-    withTempDir { tempDir =>
-      val log = DeltaLog.forTable(spark, new Path(tempDir.getCanonicalPath))
-      startTxnWithManualLogCleanup(log).commit(Nil, testOp)
-      assert(!log.enableExpiredLogCleanup())
-    }
-  }
 }