Skip to content

Commit

Permalink
HBASE-13895 DATALOSS: Region assigned before WAL replay when abort (E…
Browse files Browse the repository at this point in the history
…nis Soztutar) -- NEW ADDENDUM TO FIX ITBLL on master
  • Loading branch information
saintstack committed Jul 2, 2015
1 parent 62f5694 commit 272b025
Showing 1 changed file with 5 additions and 2 deletions.
Expand Up @@ -659,6 +659,9 @@ public int run(String[] args) throws Exception {
* WALPlayer override that searches for keys loaded in the setup.
*/
public static class WALSearcher extends WALPlayer {
public WALSearcher(Configuration conf) {
super(conf);
}

/**
* The actual searcher mapper.
Expand Down Expand Up @@ -728,12 +731,12 @@ public int run(Path inputDir, int numMappers) throws Exception {
Path oldWalsDir = new Path(hbaseDir, HConstants.HREGION_OLDLOGDIR_NAME);
LOG.info("Running Search with keys inputDir=" + inputDir +", numMappers=" + numMappers +
" against " + getConf().get(HConstants.HBASE_DIR));
int ret = ToolRunner.run(getConf(), new WALSearcher(),
int ret = ToolRunner.run(getConf(), new WALSearcher(getConf()),
new String [] {walsDir.toString(), ""});
if (ret != 0) {
return ret;
}
return ToolRunner.run(getConf(), new WALSearcher(),
return ToolRunner.run(getConf(), new WALSearcher(getConf()),
new String [] {oldWalsDir.toString(), ""});
}

Expand Down

0 comments on commit 272b025

Please sign in to comment.