fix test

Zouxxyy · Zouxxyy · commit 22f0b3c8882b · 2025-09-18T01:05:18.000+08:00
diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/listener/CustomPartitionMarkDoneActionTest.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/sink/listener/CustomPartitionMarkDoneActionTest.java
@@ -100,6 +100,6 @@ public void testCustomPartitionMarkDoneAction() throws Exception {
         assertThat(table2.fileIO().exists(successFile)).isEqualTo(true);
 
         assertThat(MockCustomPartitionMarkDoneAction.getMarkedDonePartitions().iterator().next())
-                .isEqualTo("table=default.T,partition=a=0/");
+                .isEqualTo("table=T,partition=a=0/");
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -100,6 +100,6 @@ public void testCustomPartitionMarkDoneAction() throws Exception {`
`100`	`100`	`assertThat(table2.fileIO().exists(successFile)).isEqualTo(true);`
`101`	`101`
`102`	`102`	`assertThat(MockCustomPartitionMarkDoneAction.getMarkedDonePartitions().iterator().next())`
`103`		`- .isEqualTo("table=default.T,partition=a=0/");`
	`103`	`+ .isEqualTo("table=T,partition=a=0/");`
`104`	`104`	`}`
`105`	`105`	`}`