From bb90dedfc84dc3a1aa7c3eb2e64320346f5e192c Mon Sep 17 00:00:00 2001 From: lamber-ken Date: Fri, 27 Dec 2019 01:13:47 +0800 Subject: [PATCH] [MINOR] Fix out of limits for results --- .../apache/hudi/cli/commands/HoodieLogFileCommand.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java index 77b93133f..b8ca6c0c8 100644 --- a/hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java +++ b/hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java @@ -215,9 +215,11 @@ public class HoodieLogFileCommand implements CommandMarker { if (n instanceof HoodieAvroDataBlock) { HoodieAvroDataBlock blk = (HoodieAvroDataBlock) n; List records = blk.getRecords(); - allRecords.addAll(records); - if (allRecords.size() >= limit) { - break; + for(IndexedRecord record : records) { + if (allRecords.size() >= limit) { + break; + } + allRecords.add(record); } } }