From 0d91c451b0e823162c261ec09fed9b5f4748d9e6 Mon Sep 17 00:00:00 2001 From: satishkotha Date: Fri, 19 Feb 2021 15:45:43 -0800 Subject: [PATCH] [HUDI-1539] Fix bug in HoodieCombineRealtimeRecordReader with reading empty iterators (#2583) --- .../hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java index 7a0bd37bb..615d95ee5 100644 --- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java +++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieCombineRealtimeRecordReader.java @@ -71,7 +71,7 @@ public class HoodieCombineRealtimeRecordReader implements RecordReader 0) { this.currentRecordReader.close(); this.currentRecordReader = recordReaders.remove(0); - return this.currentRecordReader.next(key, value); + return next(key, value); } else { return false; }