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 index 44a021da9a9e..7540c5171531 100644 --- 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 partitions) { try { List 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));