Repository: hbase Updated Branches: refs/heads/master 96ed407c6 -> 39cf42be9
HBASE-20476 Add more logs for debugging Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/39cf42be Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/39cf42be Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/39cf42be Branch: refs/heads/master Commit: 39cf42be9a9a3bcbf5db90903d2d4b438551d4ce Parents: 96ed407 Author: zhangduo <zhang...@apache.org> Authored: Fri Apr 27 16:02:05 2018 +0800 Committer: zhangduo <zhang...@apache.org> Committed: Fri Apr 27 16:02:05 2018 +0800 ---------------------------------------------------------------------- .../apache/hadoop/hbase/master/assignment/RegionStateStore.java | 1 + .../hadoop/hbase/master/replication/ModifyPeerProcedure.java | 3 +++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/39cf42be/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java index aa14b58..7ad6647 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/assignment/RegionStateStore.java @@ -166,6 +166,7 @@ public class RegionStateStore { if (regionInfo.getReplicaId() == RegionInfo.DEFAULT_REPLICA_ID && hasGlobalReplicationScope(regionInfo.getTable())) { MetaTableAccessor.addReplicationBarrier(put, openSeqNum); + info.append(", repBarrier=").append(openSeqNum); } info.append(", openSeqNum=").append(openSeqNum); info.append(", regionLocation=").append(regionLocation); http://git-wip-us.apache.org/repos/asf/hbase/blob/39cf42be/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.java index 0b9efce..3bb61c5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.java @@ -230,10 +230,13 @@ public abstract class ModifyPeerProcedure extends AbstractPeerProcedure<PeerModi ReplicationQueueStorage queueStorage = env.getReplicationPeerManager().getQueueStorage(); Connection conn = env.getMasterServices().getConnection(); if (!needSetLastPushedSequenceId(tsm, tableName)) { + LOG.debug("Skip settting last pushed sequence id for {}", tableName); return; } for (Pair<String, Long> name2Barrier : MetaTableAccessor .getTableEncodedRegionNameAndLastBarrier(conn, tableName)) { + // XXX: for debug only, change to trace after find out the real issues + LOG.debug("Update last pushed sequence id for {}, {}", tableName, name2Barrier); addToMap(lastSeqIds, name2Barrier.getFirst(), name2Barrier.getSecond().longValue() - 1, queueStorage); }
