diff --git a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java index ba95113d9adb..bc849f0a135f 100644 --- a/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java +++ b/paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/CompactActionITCase.java @@ -272,7 +272,7 @@ public void testUnawareBucketStreamingCompact() throws Exception { checkLatestSnapshot(table, 2, Snapshot.CommitKind.APPEND); - // repairing that the ut don't specify the real parition of table + // repairing that the ut don't specify the real partition of table runActionForUnawareTable(true); // first compaction, snapshot will be 3 @@ -314,7 +314,7 @@ public void testUnawareBucketBatchCompact() throws Exception { checkLatestSnapshot(table, 2, Snapshot.CommitKind.APPEND); - // repairing that the ut don't specify the real parition of table + // repairing that the ut don't specify the real partition of table runActionForUnawareTable(false); // first compaction, snapshot will be 3. @@ -366,7 +366,7 @@ public void testSpecifyNonPartitionField() throws Exception { rowData(1, 100, 15, BinaryString.fromString("20221209"))); Assertions.assertThatThrownBy(() -> runAction(false)) - .hasMessage("Only parition key can be specialized in compaction action."); + .hasMessage("Only partition key can be specialized in compaction action."); } @Test