From 9c74fa11f7fc8a5a87627d1bb00cc36643ec9a91 Mon Sep 17 00:00:00 2001 From: LinMingQiang Date: Fri, 24 Jan 2025 18:10:21 +0800 Subject: [PATCH] [core] fix test. --- .../paimon/flink/action/MarkPartitionDoneActionITCase.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/MarkPartitionDoneActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/MarkPartitionDoneActionITCase.java index 0a29aebf22bf..e2189f4738d4 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/MarkPartitionDoneActionITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/MarkPartitionDoneActionITCase.java @@ -167,6 +167,7 @@ public void testPartitionMarkDoneWithMultiplePartitionKey(boolean hasPk, String @MethodSource("testArguments") public void testCustomPartitionMarkDoneAction(boolean hasPk, String invoker) throws Exception { + MockCustomPartitionMarkDoneAction.getMarkedDonePartitions().clear(); Map options = new HashMap<>(2); options.put(PARTITION_MARK_DONE_ACTION.key(), SUCCESS_FILE + "," + CUSTOM); options.put( @@ -174,6 +175,7 @@ public void testCustomPartitionMarkDoneAction(boolean hasPk, String invoker) thr MockCustomPartitionMarkDoneAction.class.getName()); FileStoreTable table = prepareTable(hasPk, options); + String fullTableName = table.fullName(); switch (invoker) { case "action": @@ -217,7 +219,9 @@ public void testCustomPartitionMarkDoneAction(boolean hasPk, String invoker) thr assertThat(successFile2).isNotNull(); assertThat(MockCustomPartitionMarkDoneAction.getMarkedDonePartitions()) - .containsExactlyInAnyOrder("partKey0=0/partKey1=1/", "partKey0=1/partKey1=0/"); + .containsExactlyInAnyOrder( + "table=" + fullTableName + ",partition=partKey0=0/partKey1=1/", + "table=" + fullTableName + ",partition=partKey0=1/partKey1=0/"); } @ParameterizedTest