From d728a57fe68f174468aa3d398484491c9c37ff22 Mon Sep 17 00:00:00 2001 From: Askwang <135721692+Askwang@users.noreply.github.com> Date: Tue, 17 Dec 2024 22:24:15 +0800 Subject: [PATCH] 1 --- .../spark/procedure/CreateTagFromTimestampProcedureTest.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/CreateTagFromTimestampProcedureTest.scala b/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/CreateTagFromTimestampProcedureTest.scala index 1da05843dcf6..454b5a98bbc6 100644 --- a/paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure/CreateTagFromTimestampProcedureTest.scala +++ b/paimon-spark/paimon-spark-ut/src/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.