From e1974b546933ab2f290d95842ba5ec1a5bfcc472 Mon Sep 17 00:00:00 2001
From: yuzelin <zelin.yzl@alibaba-inc.com>
Date: Wed, 18 Dec 2024 14:11:15 +0800
Subject: [PATCH] fix

---
 .../CreateTagFromTimestampActionITTest.java      |  4 +++-
 .../CreateTagFromWatermarkActionITTest.java      | 16 ++++++++++++----
 .../flink/action/ExpireTagsActionTest.java       | 12 +++++++++---
 3 files changed, 24 insertions(+), 8 deletions(-)

diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionITTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionITTest.java
index fef369b69040..a93d04e4674f 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionITTest.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionITTest.java
@@ -67,8 +67,10 @@ public void testCreateTagFromTimestampAction() throws Exception {
                         "create_tag_from_timestamp",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + "." + tableName,
+                        tableName,
                         "--tag",
                         tag,
                         "--timestamp",
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionITTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionITTest.java
index b20974e7f44e..1198eb47f4b9 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionITTest.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionITTest.java
@@ -70,8 +70,10 @@ public void testCreateTagsFromSnapshotsWatermark() throws Exception {
                         "create_tag_from_watermark",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T",
+                        "T",
                         "--tag",
                         "tag2",
                         "--watermark",
@@ -86,8 +88,10 @@ public void testCreateTagsFromSnapshotsWatermark() throws Exception {
                         "create_tag_from_watermark",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T",
+                        "T",
                         "--tag",
                         "tag3",
                         "--watermark",
@@ -144,8 +148,10 @@ public void testCreateTagsFromTagsWatermark() throws Exception {
                         "create_tag_from_watermark",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T",
+                        "T",
                         "--tag",
                         "tag2",
                         "--watermark",
@@ -161,8 +167,10 @@ public void testCreateTagsFromTagsWatermark() throws Exception {
                         "create_tag_from_watermark",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T",
+                        "T",
                         "--tag",
                         "tag3",
                         "--watermark",
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java
index 5a156ced25be..7e204ca88492 100644
--- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java
+++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java
@@ -63,8 +63,10 @@ public void testExpireTags() throws Exception {
                         "expire_tags",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T")
+                        "T")
                 .run();
         // no tags expired
         assertThat(table.tagManager().tags().size()).isEqualTo(3);
@@ -79,8 +81,10 @@ public void testExpireTags() throws Exception {
                         "expire_tags",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T")
+                        "T")
                 .run();
         // tag-4,tag-5 expires
         assertThat(table.tagManager().tags().size()).isEqualTo(3);
@@ -96,8 +100,10 @@ public void testExpireTags() throws Exception {
                         "expire_tags",
                         "--warehouse",
                         warehouse,
+                        "--database",
+                        database,
                         "--table",
-                        database + ".T",
+                        "T",
                         "--older_than",
                         timestamp.toString())
                 .run();