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; }