diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java b/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java index 852c0b45d8..bb5485b262 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java +++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/AddPartitionRecord.java @@ -79,7 +79,7 @@ public class AddPartitionRecord { sb.append("` "); // See fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java:addPartition for details. - if (!this.range.equals(RangePartitionItem.DUMMY_ITEM)) { + if (!this.range.equals(RangePartitionItem.DUMMY_RANGE)) { // range sb.append("VALUES ["); sb.append(range.lowerEndpoint().toSql());