This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 4f7e7040ad [bugfix] (dynamic partition) dynamic partition job is
removed when tbl is sync (#23404)
4f7e7040ad is described below
commit 4f7e7040adfa8a6c4426edb4cc167ee02f4d1988
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]
