Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-9791 MR initializes scanner twice 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1533213 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
jxiang 2013-10-17 19:03:18 +00:00
parent ebd009051a
commit 0e3025566f
2 changed files with 0 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/MultiTableInputFormatBase.java
View File

@ -92,7 +92,6 @@ public abstract class MultiTableInputFormatBase extends
sc.setStopRow(tSplit.getEndRow());
trr.setScan(sc);
trr.setHTable(table);
trr.initialize(split, context);
return trr;
}

5
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableInputFormatBase.java
View File

@ -131,11 +131,6 @@ extends InputFormat<ImmutableBytesWritable, Result> {
sc.setStopRow(tSplit.getEndRow());
trr.setScan(sc);
trr.setHTable(table);
try {
trr.initialize(tSplit, context);
} catch (InterruptedException e) {
throw new InterruptedIOException(e.getMessage());
}
return trr;
}