diff --git a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java index 68f2adc2e8b..38547539227 100644 --- a/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java +++ b/hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ZKReplicationQueueStorage.java @@ -248,9 +248,9 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase return; } catch (KeeperException.BadVersionException | KeeperException.NodeExistsException e) { LOG.warn( - "Bad version(or node exist) when persist the last pushed sequence id to zookeeper storage, " - + "Retry = " + retry + ", serverName=" + serverName + ", queueId=" + queueId - + ", fileName=" + fileName); + "Bad version(or node exist) when persist the last pushed sequence id to zookeeper " + + "storage, Retry = " + retry + ", serverName=" + serverName + ", queueId=" + + queueId + ", fileName=" + fileName); } } } catch (KeeperException e) { @@ -564,7 +564,7 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase String peerNode = getHFileRefsPeerNode(peerId); try { 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 { LOG.info("Removing peer {} from hfile reference queue.", peerNode); ZKUtil.deleteNodeRecursively(zookeeper, peerNode); @@ -583,7 +583,7 @@ class ZKReplicationQueueStorage extends ZKReplicationStorageBase List listOfOps = pairs.stream().map(p -> p.getSecond().getName()) .map(n -> getHFileNode(peerNode, n)) .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()); try { ZKUtil.multiOrSequential(this.zookeeper, listOfOps, true);