feat: Filter splits that do not require compaction

apache · Apr 19, 2024 · 3165576 · 3165576
1 parent 0ed2e7b
commit 3165576
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...java/org/apache/paimon/flink/source/operator/MultiTablesBatchCompactorSourceFunction.java b/...java/org/apache/paimon/flink/source/operator/MultiTablesBatchCompactorSourceFunction.java
@@ -89,7 +89,7 @@ public void run(SourceContext<Tuple2<Split, String>> ctx) throws Exception {
                                         .filter(
                                                 split -> {
                                                     DataSplit dataSplit = (DataSplit) split;
-                                                    if (dataSplit.dataFiles().size() <= 1) {
+                                                    if (dataSplit.dataFiles().isEmpty()) {
                                                         return false;
                                                     }
                                                     return dataSplit.dataFiles().stream()