From 3d387f5f0e3e136b263725ecbf1e3961123905f4 Mon Sep 17 00:00:00 2001 From: Askwang <135721692+Askwang@users.noreply.github.com> Date: Mon, 21 Oct 2024 17:23:26 +0800 Subject: [PATCH] remove create existed tag test --- .../apache/paimon/spark/sql/PaimonTagDdlTestBase.scala | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonTagDdlTestBase.scala b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonTagDdlTestBase.scala index 08d9dceff3fa..829a6ac8576c 100644 --- a/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonTagDdlTestBase.scala +++ b/paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/PaimonTagDdlTestBase.scala @@ -64,13 +64,7 @@ abstract class PaimonTagDdlTestBase extends PaimonSparkTestBase { "PT3H") :: Nil ) - // update the tag info if tag exists - spark.sql("alter table T create tag `tag-1` RETAIN 1 HOURS") - checkAnswer( - spark.sql("select tag_name,snapshot_id,time_retained from `T$tags` where tag_name='tag-1'"), - Row("tag-1", 3, "PT1H")) - - // not update tag with 'if not exists' syntax, although tag already exists + // not update tag with 'if not exists' syntax spark.sql("alter table T create tag if not exists `tag-1` RETAIN 10 HOURS") checkAnswer( spark.sql("select tag_name,snapshot_id,time_retained from `T$tags` where tag_name='tag-1'"),