diff --git a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogGcer.java b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogGcer.java index 6dbe47ea22..468e5a0818 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogGcer.java +++ b/fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogGcer.java @@ -58,7 +58,7 @@ public class BinlogGcer extends MasterDaemon { if (tombstones != null && !tombstones.isEmpty()) { LOG.info("tomebstones size: {}", tombstones.size()); } else { - LOG.info("no gc binlogg"); + LOG.info("no gc binlog"); return; } diff --git a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java index 5641ff077d..191cc529bf 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java +++ b/fe/fe-core/src/main/java/org/apache/doris/clone/DynamicPartitionScheduler.java @@ -501,11 +501,12 @@ public class DynamicPartitionScheduler extends MasterDaemon { olapTable = (OlapTable) db.getTableNullable(tableId); // Only OlapTable has DynamicPartitionProperty if (olapTable == null - || olapTable.isBeingSynced() || !olapTable.dynamicPartitionExists() || !olapTable.getTableProperty().getDynamicPartitionProperty().getEnable()) { iterator.remove(); continue; + } else if (olapTable.isBeingSynced()) { + continue; } olapTable.readLock(); try {