1

apache · Dec 18, 2023 · c6902b1 · c6902b1
1 parent ddc359e
commit c6902b1
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 7 deletions.
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
@@ -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
@@ -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/...core/src/main/java/org/apache/doris/nereids/trees/plans/commands/info/CreateMTMVInfo.java b/...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<String> partitionColumnNames;
+            Set<String> 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) {