Repository: hbase Updated Branches: refs/heads/master e8e658ed3 -> f3bed5b0d
HBASE-17026 VerifyReplication log should distinguish whether good row key is result of revalidation Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f3bed5b0 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f3bed5b0 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f3bed5b0 Branch: refs/heads/master Commit: f3bed5b0d98b3cb895e81b20f5e3017081b74972 Parents: e8e658e Author: tedyu <yuzhih...@gmail.com> Authored: Mon Nov 7 07:38:47 2016 -0800 Committer: tedyu <yuzhih...@gmail.com> Committed: Mon Nov 7 07:38:47 2016 -0800 ---------------------------------------------------------------------- .../hadoop/hbase/mapreduce/replication/VerifyReplication.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/f3bed5b0/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java index 5f804dc..09d1cc8 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java @@ -211,18 +211,19 @@ public class VerifyReplication extends Configured implements Tool { if (!sourceResult.isEmpty()) { context.getCounter(Counters.GOODROWS).increment(1); 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; } catch (Exception e) { 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(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); }