fix

Signed-off-by: gengjun-git <gengjun@starrocks.com>
StarRocks · Aug 15, 2024 · 14434f0 · 14434f0
1 parent 7f06816
commit 14434f0
Showing 1 changed file with 11 additions and 6 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/catalog/CatalogUtils.java b/fe/fe-core/src/main/java/com/starrocks/catalog/CatalogUtils.java
@@ -214,14 +214,19 @@ public static void checkTempPartitionConflict(List<Partition> partitionList,
         Set<List<Object>> tempMultiSet = new HashSet<>();
         for (Partition partition : tempPartitionList) {
             if (listPartitionInfo.isMultiColumnPartition()) {
-                multiListMap.get(partition.getId()).forEach(itemList -> {
-                    List<Object> cur = new ArrayList<>();
-                    itemList.forEach(item -> cur.add(item.getRealObjectValue()));
-                    tempMultiSet.add(cur);
-                });
+                tempMultiSet = multiListMap.get(partition.getId())
+                        .stream()
+                        .map(literalExprs -> literalExprs
+                                .stream()
+                                .map(LiteralExpr::getRealObjectValue)
+                                .collect(Collectors.toList()))
+                        .collect(Collectors.toSet());
                 newMultiListMap.remove(partition.getId());
             } else {
-                listMap.get(partition.getId()).forEach(item -> tempSet.add(item.getRealObjectValue()));
+                tempSet = listMap.get(partition.getId())
+                        .stream()
+                        .map(LiteralExpr::getRealObjectValue)
+                        .collect(Collectors.toSet());
                 newListMap.remove(partition.getId());
             }
         }