Skip to content

Commit 5cd3d10

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

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
@@ -1048,7 +1048,7 @@ private void checkMVPartitionInfoType(CreateMaterializedViewStatement statement,
10481048
} else {
10491049
List<Column> refPartitionCols = refBaseTable.getPartitionColumns();
10501050
Optional<Column> refPartitionColOpt = refPartitionCols.stream()
1051-
.filter(col -> col.getName().equals(slotRef.getColumnName()))
1051+
.filter(col -> col.getName().equalsIgnoreCase(slotRef.getColumnName()))
10521052
.findFirst();
10531053
if (refPartitionColOpt.isEmpty()) {
10541054
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
@@ -551,4 +551,10 @@ public void testReplicationNum() throws Exception {
551551

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

0 commit comments

Comments
 (0)