This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new baa44fd3f [doc] Fix CompactionAction doc misspelling (#4238)
baa44fd3f is described below
commit baa44fd3f237a90b74254062647241135896d95c
Author: dongsj <[email protected]>
AuthorDate: Wed Sep 25 12:02:29 2024 +0800
[doc] Fix CompactionAction doc misspelling (#4238)
---
.../src/main/java/org/apache/paimon/flink/action/CompactAction.java | 4 ++--
.../java/org/apache/paimon/flink/action/CompactActionITCase.java | 6 +++---
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
index 19c209709..8ea120015 100644
---
a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
+++
b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/CompactAction.java
@@ -186,14 +186,14 @@ public class CompactAction extends TableActionBase {
predicate =
simpleSqlPredicateConvertor.convertSqlToPredicate(whereSql);
}
- // Check whether predicate contain non parition key.
+ // Check whether predicate contain non partition key.
if (predicate != null) {
LOGGER.info("the partition predicate of compaction is {}",
predicate);
PartitionPredicateVisitor partitionPredicateVisitor =
new PartitionPredicateVisitor(table.partitionKeys());
Preconditions.checkArgument(
predicate.visit(partitionPredicateVisitor),
- "Only parition key can be specialized in compaction
action.");
+ "Only partition key can be specialized in compaction
action.");
}
return predicate;
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 ba95113d9..bc849f0a1 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 class CompactActionITCase extends
CompactActionITCaseBase {
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 class CompactActionITCase extends
CompactActionITCaseBase {
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 class CompactActionITCase extends
CompactActionITCaseBase {
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
