database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: [Bug](materialized-view) Fixed the problem of using drop table force and create mv stmt at the… #41580 (#50133)

Browse Source 
Cherry-picked from #41580

Co-authored-by: Pxl <pxl290@qq.com>
This commit is contained in:
github-actions[bot]
2025-04-18 11:30:47 +08:00
committed by GitHub
parent c3a201dcbf
commit 77ea907b54
2 changed files with 57 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
fe/fe-core/src/main/java/org/apache/doris/alter/RollupJobV2.java
View File

@ -886,7 +886,11 @@ public class RollupJobV2 extends AlterJobV2 implements GsonPostProcessable {
stmt.analyze(analyzer);
} catch (Exception e) {
// Under normal circumstances, the stmt will not fail to analyze.
throw new IOException("error happens when parsing create materialized view stmt: " + stmt, e);
// In some cases (such as drop table force), analyze may fail because cancel is
// not included in the checkpoint.
jobState = JobState.CANCELLED;
LOG.warn("error happens when parsing create materialized view stmt: " + stmt, e);
return;
}
setColumnsDefineExpr(stmt.getMVColumnItemList());
}

52
regression-test/suites/mv_p0/mv_with_force_drop/mv_with_force_drop.groovy Normal file
View File

@ -0,0 +1,52 @@
// 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.
suite("mv_with_force_drop") {
sql """
drop table if exists test_table_t1;
"""
sql """
CREATE TABLE test_table_t1 (
a1 varchar(65533) NULL default '123',
a2 varchar(64) NULL default '',
a3 varchar(65533) NULL default '',
a4 varchar(65533) NULL default '',
a5 varchar(64) default '2023-01-31',
a6 varchar(64) default ''
) ENGINE = OLAP
DUPLICATE KEY(a1)
DISTRIBUTED BY HASH(a1) BUCKETS 3
PROPERTIES (
"replication_allocation"="tag.location.default:1",
"is_being_synced"="false",
"storage_format"="V2",
"disable_auto_compaction"="false",
"enable_single_replica_compaction"="false"
);
"""
sql """ insert into test_table_t1 values(); """
// create mv and do not wait ready
sql """ CREATE MATERIALIZED VIEW test_table_view As
select a1,a3,a4,DATE_FORMAT(a5, 'yyyyMMdd') QUERY_TIME,DATE_FORMAT(a6 ,'yyyyMMdd') CREATE_TIME
from test_table_t1 where DATE_FORMAT(a5, 'yyyyMMdd') =20230131; """
// drop table force immediately
sql """
drop table if exists test_table_t1 force;
"""
}