From 4f7e7040adfa8a6c4426edb4cc167ee02f4d1988 Mon Sep 17 00:00:00 2001 From: DeadlineFen <117912096+deadlinefen@users.noreply.github.com> Date: Tue, 29 Aug 2023 20:35:56 +0800 Subject: [PATCH] [bugfix] (dynamic partition) dynamic partition job is removed when tbl is sync (#23404) --- .../src/main/java/org/apache/doris/binlog/BinlogGcer.java | 2 +- .../java/org/apache/doris/clone/DynamicPartitionScheduler.java | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) 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 {