From e8ef8ad42f535131a5866704635c36edbd8db8b0 Mon Sep 17 00:00:00 2001 From: Jan Hentschel Date: Fri, 3 May 2019 13:02:53 +0200 Subject: [PATCH] HBASE-22357 Fixed remaining Checkstyle issues in hbase-replication --- .../hbase/replication/ZKReplicationQueueStorage.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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);