I am writing my custom InputFormat to read N number of lines per map task. For this I have extended the FileInputFormat and RecordReader classes.
In my RecordReader I am using LineRecordReader object to get key value pairs. If I am calling LineRecordReaderObj.nextKeyValue() method multiple times while handling the same file SPLIT, it goes to the next keyValue but the following functions return same keyValue every time: getCurrentKey() / getCurrentValue() What may be the possible reason for this behavior?
