This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 7ecf088a619 [enhance](mtmv)when drop temp partition, not trigger
materialized vie… (#40993)
7ecf088a619 is described below
commit 7ecf088a6197800ef6ae2b66672dc9c8c770dd63
Author: zhangdong <493738...@qq.com>
AuthorDate: Thu Sep 19 22:35:31 2024 +0800
[enhance](mtmv)when drop temp partition, not trigger materialized vie…
(#40993)
…w refresh (#40875)
pick: https://github.com/apache/doris/pull/40875
---
.../main/java/org/apache/doris/datasource/InternalCatalog.java | 2 +-
.../src/main/java/org/apache/doris/event/DropPartitionEvent.java | 9 ++++++++-
fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVService.java | 4 ++++
3 files changed, 13 insertions(+), 2 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
index 748b6671c7a..ceccc895247 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/datasource/InternalCatalog.java
@@ -1889,7 +1889,7 @@ public class InternalCatalog implements
CatalogIf<Database> {
// it does not affect the logic of deleting the partition
try {
Env.getCurrentEnv().getEventProcessor().processEvent(
- new DropPartitionEvent(db.getCatalog().getId(),
db.getId(), olapTable.getId()));
+ new DropPartitionEvent(db.getCatalog().getId(),
db.getId(), olapTable.getId(), isTempPartition));
} catch (Throwable t) {
// According to normal logic, no exceptions will be thrown,
// but in order to avoid bugs affecting the original logic, all
exceptions are caught
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/event/DropPartitionEvent.java
b/fe/fe-core/src/main/java/org/apache/doris/event/DropPartitionEvent.java
index 598768aa8de..cea03e7ef79 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/event/DropPartitionEvent.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/event/DropPartitionEvent.java
@@ -20,7 +20,14 @@ package org.apache.doris.event;
import org.apache.doris.common.AnalysisException;
public class DropPartitionEvent extends TableEvent {
- public DropPartitionEvent(long ctlId, long dbId, long tableId) throws
AnalysisException {
+ private boolean isTempPartition;
+
+ public DropPartitionEvent(long ctlId, long dbId, long tableId, boolean
isTempPartition) throws AnalysisException {
super(EventType.DROP_PARTITION, ctlId, dbId, tableId);
+ this.isTempPartition = isTempPartition;
+ }
+
+ public boolean isTempPartition() {
+ return isTempPartition;
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVService.java
b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVService.java
index 4b740b75ef8..278811d3a99 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVService.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mtmv/MTMVService.java
@@ -24,6 +24,7 @@ import org.apache.doris.catalog.TableIf;
import org.apache.doris.common.AnalysisException;
import org.apache.doris.common.DdlException;
import org.apache.doris.common.MetaNotFoundException;
+import org.apache.doris.event.DropPartitionEvent;
import org.apache.doris.event.Event;
import org.apache.doris.event.EventException;
import org.apache.doris.event.EventListener;
@@ -177,6 +178,9 @@ public class MTMVService implements EventListener {
if (!(event instanceof TableEvent)) {
return;
}
+ if (event instanceof DropPartitionEvent && ((DropPartitionEvent)
event).isTempPartition()) {
+ return;
+ }
TableEvent tableEvent = (TableEvent) event;
LOG.info("processEvent, Event: {}", event);
TableIf table;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
