Skip to content

Commit 44e7c9f

Browse files
[BugFix] Fix case-sensitive partition column validation in materialized view analyzer (backport #62598) (#62621)
Signed-off-by: stephen <stephen5217@163.com> Co-authored-by: stephen <91597003+stephen-shelby@users.noreply.github.com>
1 parent 223a985 commit 44e7c9f

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

fe/fe-core/src/main/java/com/starrocks/sql/analyzer/MaterializedViewAnalyzer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1051,7 +1051,7 @@ private void checkMVPartitionInfoType(CreateMaterializedViewStatement statement,
10511051
} else {
10521052
List<Column> refPartitionCols = refBaseTable.getPartitionColumns();
10531053
Optional<Column> refPartitionColOpt = refPartitionCols.stream()
1054-
.filter(col -> col.getName().equals(slotRef.getColumnName()))
1054+
.filter(col -> col.getName().equalsIgnoreCase(slotRef.getColumnName()))
10551055
.findFirst();
10561056
if (refPartitionColOpt.isEmpty()) {
10571057
throw new SemanticException("Materialized view partition column in partition exp " +

fe/fe-core/src/test/java/com/starrocks/sql/analyzer/MaterializedViewAnalyzerTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -550,4 +550,10 @@ public void testReplicationNum() throws Exception {
550550

551551
Config.default_replication_num = defaultReplication;
552552
}
553+
554+
@Test
555+
public void testCreateMVCheckPartitionNameIgnoreCaseSensitive() {
556+
analyzeSuccess("create materialized view mv_hive_0 partition by str2date(L_SHIPDATE, '%Y%m%d') refresh manual as " +
557+
"SELECT l_partkey, L_SHIPDATE FROM hive0.partitioned_db.lineitem_mul_par3 as a");
558+
}
553559
}

0 commit comments

Comments
 (0)