This is an automated email from the ASF dual-hosted git repository.

kxiao pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git

commit 86e303df0c67c15fcb0af6b8b82dda3c3d466b66
Author: DeadlineFen <[email protected]>
AuthorDate: Tue Aug 29 20:35:56 2023 +0800

    [bugfix] (dynamic partition)  dynamic partition job is removed when tbl is 
sync (#23404)
---
 fe/fe-core/src/main/java/org/apache/doris/binlog/BinlogGcer.java       | 2 +-
 .../main/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 {


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to