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

HBASE-16135 addendum format comments

This commit is contained in:
zhangduo 2016-07-04 20:41:06 +08:00
parent 721c5b7128
commit 4807836304
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/ReplicationSourceManager.java
View File

@ -389,8 +389,8 @@ public class ReplicationSourceManager implements ReplicationListener {
String logName = logPath.getName(); String logName = logPath.getName();
String logPrefix = DefaultWALProvider.getWALPrefixFromWALName(logName); String logPrefix = DefaultWALProvider.getWALPrefixFromWALName(logName);
// update replication queues on ZK // update replication queues on ZK
synchronized (replicationPeers) {// synchronize on replicationPeers to avoid adding source for // synchronize on replicationPeers to avoid adding source for the to-be-removed peer
// the to-be-removed peer synchronized (replicationPeers) {
for (String id : replicationPeers.getPeerIds()) { for (String id : replicationPeers.getPeerIds()) {
try { try {
this.replicationQueues.addLog(id, logName); this.replicationQueues.addLog(id, logName);