From f96dfe0ffb533ae343f23ede2f6970d8131f67d6 Mon Sep 17 00:00:00 2001
From: seawinde <wusi@selectdb.com>
Date: Tue, 24 Jun 2025 17:08:05 +0800
Subject: [PATCH 1/2] [fix](mtmv) Fix compensate union all wrongly when
 partition mv use partition external table

---
 .../nereids/rules/exploration/mv/PartitionCompensator.java    | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
index 98629f86028b81..67a02517406c89 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
@@ -84,8 +84,10 @@ public static Pair<Map<BaseTableInfo, Set<String>>, Map<BaseTableInfo, Set<Strin
         }
         MTMVPartitionInfo mvCustomPartitionInfo = mtmv.getMvPartitionInfo();
         BaseTableInfo relatedPartitionTable = mvCustomPartitionInfo.getRelatedTableInfo();
-        if (relatedPartitionTable == null || queryUsedBaseTablePartitionNameSet.isEmpty()) {
+        if (relatedPartitionTable == null || queryUsedBaseTablePartitionNameSet.isEmpty()
+                || !relatedPartitionTable.isInternalTable()) {
             // if mv is not partitioned or query not query any partition, doesn't compensate
+            // in 2.1, external table should not compensate union all
             return Pair.of(ImmutableMap.of(), ImmutableMap.of());
         }
         Collection<Partition> mvValidPartitions = cascadesContext.getStatementContext()

From 79e3b4a4453707b06bad5b032c08b618af5dc301 Mon Sep 17 00:00:00 2001
From: seawinde <wusi@selectdb.com>
Date: Wed, 25 Jun 2025 09:38:18 +0800
Subject: [PATCH 2/2] fix regression test

---
 .../nereids/rules/exploration/mv/PartitionCompensator.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
index 67a02517406c89..13cab34c783163 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/rules/exploration/mv/PartitionCompensator.java
@@ -87,7 +87,7 @@ public static Pair<Map<BaseTableInfo, Set<String>>, Map<BaseTableInfo, Set<Strin
         if (relatedPartitionTable == null || queryUsedBaseTablePartitionNameSet.isEmpty()
                 || !relatedPartitionTable.isInternalTable()) {
             // if mv is not partitioned or query not query any partition, doesn't compensate
-            // in 2.1, external table should not compensate union all
+            // in 3.0, external table should not compensate union all
             return Pair.of(ImmutableMap.of(), ImmutableMap.of());
         }
         Collection<Partition> mvValidPartitions = cascadesContext.getStatementContext()