diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java index fbdc213f1ff259..caab7d428fed22 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java +++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/MTMV.java @@ -188,7 +188,7 @@ public long getGracePeriod() { public int getRefreshPartitionNum() { if (mvProperties.containsKey(PropertyAnalyzer.PROPERTIES_REFRESH_PARTITION_NUM)) { int value = Integer.parseInt(mvProperties.get(PropertyAnalyzer.PROPERTIES_REFRESH_PARTITION_NUM)); - return value < 1 ? 1 : value; + return value < 1 ? MTMVTask.DEFAULT_REFRESH_PARTITION_NUM : value; } else { return MTMVTask.DEFAULT_REFRESH_PARTITION_NUM; } diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java index ef1edc84947c49..439268fa0b92e1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java +++ b/fe/fe-core/src/main/java/org/apache/doris/job/extensions/mtmv/MTMVTask.java @@ -261,9 +261,7 @@ private String getProgress() { BigDecimal result = new BigDecimal(completedSize * 100) .divide(new BigDecimal(needRefreshPartitions.size()), 2, RoundingMode.HALF_UP); StringBuilder builder = new StringBuilder(result.toString()); - builder.append("%"); - builder.append(" "); - builder.append("("); + builder.append("% ("); builder.append(completedSize); builder.append("/"); builder.append(needRefreshPartitions.size()); diff --git a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java index ab17401797cac2..c8a4bfeebb1c68 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java +++ b/fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java @@ -240,14 +240,14 @@ private void analyzePartition(NereidsPlanner planner) { if (!(followTable instanceof OlapTable)) { throw new AnalysisException("base table for partitioning only can be OlapTable."); } - Set partitionColumnNames; + Set partitionColumnNames = Sets.newTreeSet(String.CASE_INSENSITIVE_ORDER); try { - partitionColumnNames = ((OlapTable) followTable).getPartitionColumnNames(); + partitionColumnNames.addAll(((OlapTable) followTable).getPartitionColumnNames()); } catch (DdlException e) { throw new AnalysisException(e.getMessage(), e); } - if (!partitionColumnNames.contains(relatedTableInfo.get().getColumn().toLowerCase())) { + if (!partitionColumnNames.contains(relatedTableInfo.get().getColumn())) { throw new AnalysisException("error related column: " + relatedTableInfo.get().getColumn()); } if (partitionColumnNames.size() != 1) {