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

HBASE-17026 VerifyReplication log should distinguish whether good row key is result of revalidation

Browse Source
This commit is contained in:
tedyu 2016-11-07 07:38:47 -08:00
parent e8e658ed38
commit f3bed5b0d9
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java
View File

@ -211,18 +211,19 @@ public class VerifyReplication extends Configured implements Tool {
if (!sourceResult.isEmpty()) { if (!sourceResult.isEmpty()) {
context.getCounter(Counters.GOODROWS).increment(1); context.getCounter(Counters.GOODROWS).increment(1);
if (verbose) { if (verbose) {
LOG.info("Good row key: " + delimiter + Bytes.toString(row.getRow()) + delimiter); LOG.info("Good row key (with recompare): " + delimiter + Bytes.toStringBinary(row.getRow())
+ delimiter);
} }
} }
return; return;
} catch (Exception e) { } catch (Exception e) {
LOG.error("recompare fail after sleep, rowkey=" + delimiter + LOG.error("recompare fail after sleep, rowkey=" + delimiter +
Bytes.toString(row.getRow()) + delimiter); Bytes.toStringBinary(row.getRow()) + delimiter);
} }
} }
context.getCounter(counter).increment(1); context.getCounter(counter).increment(1);
context.getCounter(Counters.BADROWS).increment(1); context.getCounter(Counters.BADROWS).increment(1);
LOG.error(counter.toString() + ", rowkey=" + delimiter + Bytes.toString(row.getRow()) + LOG.error(counter.toString() + ", rowkey=" + delimiter + Bytes.toStringBinary(row.getRow()) +
delimiter); delimiter);
} }