1

Zouxxyy · Nov 7, 2024 · f0e928a · f0e928a
1 parent 6e9c40a
commit f0e928a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/paimon-core/src/main/java/org/apache/paimon/metastore/AddPartitionCommitCallback.java b/paimon-core/src/main/java/org/apache/paimon/metastore/AddPartitionCommitCallback.java
@@ -90,7 +90,9 @@ private void addPartitions(Set<BinaryRow> partitions) {
         try {
             List<BinaryRow> filteredPartitions = new ArrayList<>();
             for (BinaryRow partition : partitions) {
-                if (!cache.get(partition, () -> false)) filteredPartitions.add(partition);
+                if (!cache.get(partition, () -> false)) {
+                    filteredPartitions.add(partition);
+                }
             }
             client.addPartitions(filteredPartitions);
             filteredPartitions.forEach(partition -> cache.put(partition, true));