Skip to content

Commit aec272f

Browse files
author
Ahmed Eldawy
committed
Fixed a bug with BinaryRecordReader
1 parent 61e9fb4 commit aec272f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/mapred/org/apache/hadoop/mapred/spatial/BinaryRecordReader.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ protected abstract RecordReader<K, V> createRecordReader(Configuration conf,
4646
public BinaryRecordReader(Configuration conf, CombineFileSplit split) throws IOException {
4747
this.conf = conf;
4848
this.split = split;
49-
internalReaders = new RecordReader[(int) split.getLength()];
49+
internalReaders = new RecordReader[(int) split.getNumPaths()];
5050
// Initialize all record readers
5151
for (int i = 0; i < split.getNumPaths(); i++) {
5252
this.internalReaders[i] = createRecordReader(this.conf, this.split, i);

0 commit comments

Comments
 (0)