Skip to content

Commit 46fa990

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

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
@@ -873,7 +873,7 @@ private void determinePartitionType(CreateMaterializedViewStatement statement,
873873
} else {
874874
List<Column> refPartitionCols = refBaseTable.getPartitionColumns();
875875
Optional<Column> refPartitionColOpt = refPartitionCols.stream()
876-
.filter(col -> col.getName().equals(slotRef.getColumnName()))
876+
.filter(col -> col.getName().equalsIgnoreCase(slotRef.getColumnName()))
877877
.findFirst();
878878
if (refPartitionColOpt.isEmpty()) {
879879
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
@@ -515,4 +515,10 @@ public void testReplicationNum() throws Exception {
515515

516516
Config.default_replication_num = defaultReplication;
517517
}
518+
519+
@Test
520+
public void testCreateMVCheckPartitionNameIgnoreCaseSensitive() {
521+
analyzeSuccess("create materialized view mv_hive_0 partition by str2date(L_SHIPDATE, '%Y%m%d') refresh manual as " +
522+
"SELECT l_partkey, L_SHIPDATE FROM hive0.partitioned_db.lineitem_mul_par3 as a");
523+
}
518524
}

0 commit comments

Comments
 (0)