This is an automated email from the ASF dual-hosted git repository. sivabalan pushed a commit to branch release-0.12.2-shadow in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 2e358b386d2f8e69b9584ba36c2b4067951d10cc Author: vamshigv <[email protected]> AuthorDate: Mon Dec 12 00:59:59 2022 -0800 [MINOR] Fix Out of Bounds Exception for DayBasedCompactionStrategy (#7360) --- .../hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java index 94d74b50dc2..424ce51d1ef 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/strategy/DayBasedCompactionStrategy.java @@ -78,7 +78,8 @@ public class DayBasedCompactionStrategy extends CompactionStrategy { 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())); } /**
