From 913a3e48f1368fb090e823f78a0312b7de7451e0 Mon Sep 17 00:00:00 2001 From: Carmen Kwan Date: Fri, 23 Jan 2026 20:22:46 +0100 Subject: [PATCH] [Spark][REFACTOR][TEST-ONLY] Move test from DeltaRetentionSuiteBase to DeltaRetentionSuite --- .../org/apache/spark/sql/delta/DeltaRetentionSuite.scala | 8 ++++++++ .../apache/spark/sql/delta/DeltaRetentionSuiteBase.scala | 8 -------- 2 files changed, 8 insertions(+), 8 deletions(-) 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()) - } - } }