You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2016/11/07 15:38:59 UTC
hbase git commit: HBASE-17026 VerifyReplication log should
distinguish whether good row key is result of revalidation
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 <yu...@gmail.com>
Authored: Mon Nov 7 07:38:47 2016 -0800
Committer: tedyu <yu...@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);
}