[MINOR] Fix Out of Bounds Exception for DayBasedCompactionStrategy (a…

…pache#7360)
onehouseinc · Dec 14, 2022 · c423e20 · c423e20
1 parent 2f28fb2
commit c423e20
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...c/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java b/...c/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java
@@ -78,7 +78,8 @@ public List<HoodieCompactionOperation> orderAndFilter(HoodieWriteConfig writeCon
   public List<String> filterPartitionPaths(HoodieWriteConfig writeConfig, List<String> allPartitionPaths) {
     return allPartitionPaths.stream().map(partition -> partition.replace("/", "-"))
         .sorted(Comparator.reverseOrder()).map(partitionPath -> partitionPath.replace("-", "/"))
-        .collect(Collectors.toList()).subList(0, writeConfig.getTargetPartitionsPerDayBasedCompaction());
+        .collect(Collectors.toList()).subList(0, Math.min(allPartitionPaths.size(),
+            writeConfig.getTargetPartitionsPerDayBasedCompaction()));
   }
 
   /**