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 19c209709b5c5..8ea120015609c 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 @@ protected Predicate getPredicate() throws Exception {
             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;