From 5a0b5839727ba8c9504e84cd759dc0e45b292522 Mon Sep 17 00:00:00 2001
From: zhangdong <zhangdong@selectdb.com>
Date: Wed, 27 Nov 2024 20:07:35 +0800
Subject: [PATCH] [fix](insertoverwrite)fix roll up will lose after insert
 overwrite (#41888)

The implementation method on NEREIDS is different, so there is no
problem, so it was only fixed in 2.0
---
 .../org/apache/doris/qe/StmtExecutor.java     |  2 +-
 .../insert_overwrite_rollup.groovy            | 54 +++++++++++++++++++
 2 files changed, 55 insertions(+), 1 deletion(-)
 create mode 100644 regression-test/suites/insert_overwrite_p0/insert_overwrite_rollup.groovy

diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 0e09640ba2c8f3..89ca99fb8dc5f7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -2581,7 +2581,7 @@ private void handleOverwriteTable(InsertOverwriteTableStmt iotStmt) {
         TableName targetTableName = new TableName(null, iotStmt.getDb(), iotStmt.getTbl());
         try {
             // create a tmp table with uuid
-            parsedStmt = new CreateTableLikeStmt(false, tmpTableName, targetTableName, null, false);
+            parsedStmt = new CreateTableLikeStmt(false, tmpTableName, targetTableName, null, true);
             parsedStmt.setUserInfo(context.getCurrentUserIdentity());
             execute();
             // if create tmp table err, return
diff --git a/regression-test/suites/insert_overwrite_p0/insert_overwrite_rollup.groovy b/regression-test/suites/insert_overwrite_p0/insert_overwrite_rollup.groovy
new file mode 100644
index 00000000000000..64a24f28e98ef3
--- /dev/null
+++ b/regression-test/suites/insert_overwrite_p0/insert_overwrite_rollup.groovy
@@ -0,0 +1,54 @@
+// Licensed to the Apache Software Foundation (ASF) under one  
+// or more contributor license agreements.  See the NOTICE file
+// distributed with this work for additional information       
+// regarding copyright ownership.  The ASF licenses this file  
+// to you under the Apache License, Version 2.0 (the           
+// "License"); you may not use this file except in compliance
+// with the License.  You may obtain a copy of the License at
+//
+//   http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing,
+// software distributed under the License is distributed on an
+// "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+// KIND, either express or implied.  See the License for the
+// specific language governing permissions and limitations
+// under the License.
+
+import org.junit.Assert;
+
+suite("insert_overwrite_rollup","p0") {
+    String suiteName = "insert_overwrite_not_fallback"
+    String tableName = "${suiteName}_table"
+    String rollupName = "${suiteName}_rollup"
+    sql """drop table if exists `${tableName}`"""
+    sql """
+    CREATE TABLE `${tableName}`
+      (
+          k2 TINYINT,
+          k3 INT not null
+      )
+      COMMENT "my first table"
+      PARTITION BY LIST(`k3`)
+      (
+          PARTITION `p1` VALUES IN ('1'),
+          PARTITION `p2` VALUES IN ('2'),
+          PARTITION `p3` VALUES IN ('3')
+      )
+      DISTRIBUTED BY HASH(k2) BUCKETS 2
+      ROLLUP (
+          ${rollupName}(k3)
+      )
+      PROPERTIES (
+          "replication_num" = "1"
+      );
+    """
+    sql """
+        insert overwrite table ${tableName} values(1,1);
+        """
+    def res = sql "desc ${tableName} all"
+    logger.info("res: " + res.toString())
+    assertTrue(res.toString().contains("${rollupName}"))
+    sql """drop table if exists `${tableName}`"""
+}
+