fix

apache · Dec 18, 2024 · e1974b5 · e1974b5
1 parent 1a84ac6
commit e1974b5
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 8 deletions.
diff --git a/...mmon/src/test/java/org/apache/paimon/flink/action/CreateTagFromTimestampActionITTest.java b/...mmon/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/...mmon/src/test/java/org/apache/paimon/flink/action/CreateTagFromWatermarkActionITTest.java b/...mmon/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/...aimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java b/...aimon-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();