lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Fix out of limits for results

Browse Source
This commit is contained in:
lamber-ken
2019-12-27 01:13:47 +08:00
parent 842eabb27f
commit bb90dedfc8
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java
View File

@@ -215,9 +215,11 @@ public class HoodieLogFileCommand implements CommandMarker {
if (n instanceof HoodieAvroDataBlock) { if (n instanceof HoodieAvroDataBlock) {
HoodieAvroDataBlock blk = (HoodieAvroDataBlock) n; HoodieAvroDataBlock blk = (HoodieAvroDataBlock) n;
List<IndexedRecord> records = blk.getRecords(); List<IndexedRecord> records = blk.getRecords();
allRecords.addAll(records); for(IndexedRecord record : records) {
if (allRecords.size() >= limit) { if (allRecords.size() >= limit) {
break; break;
}
allRecords.add(record);
} }
} }
} }