hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhang...@apache.org
Subject [09/43] hbase git commit: HBASE-20476 Add more logs for debugging
Date Wed, 02 May 2018 02:58:59 GMT
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/HBASE-19064
Commit: 39cf42be9a9a3bcbf5db90903d2d4b438551d4ce
Parents: 96ed407
Author: zhangduo <zhangduo@apache.org>
Authored: Fri Apr 27 16:02:05 2018 +0800
Committer: zhangduo <zhangduo@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);
     }


Mime
View raw message