1

askwang · Dec 17, 2024 · d728a57 · d728a57
1 parent f0f5b47
commit d728a57
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...rc/test/scala/org/apache/paimon/spark/procedure/CreateTagFromTimestampProcedureTest.scala b/...rc/test/scala/org/apache/paimon/spark/procedure/CreateTagFromTimestampProcedureTest.scala
@@ -148,7 +148,8 @@ class CreateTagFromTimestampProcedureTest extends PaimonSparkTestBase with Strea
 
             // make snapshot 1 expire.
             checkAnswer(
-              spark.sql("CALL paimon.sys.expire_snapshots(table => 'test.T', retain_max => 1)"),
+              spark.sql(
+                "CALL paimon.sys.expire_snapshots(table => 'test.T', retain_max => 1, retain_min => 1)"),
               Row(1) :: Nil)
 
             // create tag from timestamp that earlier than the expired snapshot 1.