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

HBASE-22357 Fixed remaining Checkstyle issues in hbase-replication

This commit is contained in:
Jan Hentschel 2019-05-03 13:02:53 +02:00
parent 5ae8bc4974
commit 48f2144c73
No known key found for this signature in database
GPG Key ID: 5CD818B19CC299A3
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java
View File

@ -248,9 +248,9 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase
return; return;
} catch (KeeperException.BadVersionException | KeeperException.NodeExistsException e) { } catch (KeeperException.BadVersionException | KeeperException.NodeExistsException e) {
LOG.warn( LOG.warn(
"Bad version(or node exist) when persist the last pushed sequence id to zookeeper storage, " "Bad version(or node exist) when persist the last pushed sequence id to zookeeper "
+ "Retry = " + retry + ", serverName=" + serverName + ", queueId=" + queueId + "storage, Retry = " + retry + ", serverName=" + serverName + ", queueId="
+ ", fileName=" + fileName); + queueId + ", fileName=" + fileName);
} }
} }
} catch (KeeperException e) { } catch (KeeperException e) {
@ -564,7 +564,7 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase
String peerNode = getHFileRefsPeerNode(peerId); String peerNode = getHFileRefsPeerNode(peerId);
try { try {
if (ZKUtil.checkExists(zookeeper, peerNode) == -1) { if (ZKUtil.checkExists(zookeeper, peerNode) == -1) {
LOG.debug("Peer {} not found in hfile reference queue.", peerNode); LOG.debug("Peer {} not found in hfile reference queue.", peerNode);
} else { } else {
LOG.info("Removing peer {} from hfile reference queue.", peerNode); LOG.info("Removing peer {} from hfile reference queue.", peerNode);
ZKUtil.deleteNodeRecursively(zookeeper, peerNode); ZKUtil.deleteNodeRecursively(zookeeper, peerNode);
@ -583,7 +583,7 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase
List<ZKUtilOp> listOfOps = pairs.stream().map(p -> p.getSecond().getName()) List<ZKUtilOp> listOfOps = pairs.stream().map(p -> p.getSecond().getName())
.map(n -> getHFileNode(peerNode, n)) .map(n -> getHFileNode(peerNode, n))
.map(f -> ZKUtilOp.createAndFailSilent(f, HConstants.EMPTY_BYTE_ARRAY)).collect(toList()); .map(f -> ZKUtilOp.createAndFailSilent(f, HConstants.EMPTY_BYTE_ARRAY)).collect(toList());
LOG.debug("The multi list size for adding hfile references in zk for node {} is {}", LOG.debug("The multi list size for adding hfile references in zk for node {} is {}",
peerNode, listOfOps.size()); peerNode, listOfOps.size());
try { try {
ZKUtil.multiOrSequential(this.zookeeper, listOfOps, true); ZKUtil.multiOrSequential(this.zookeeper, listOfOps, true);