[hbase] branch branch-2.1 updated: HBASE-22357 Fixed remaining Checkstyle issues in hbase-replication

[janh]

This is an automated email from the ASF dual-hosted git repository.

janh pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/hbase.git


The following commit(s) were added to refs/heads/branch-2.1 by this push:
     new 48f2144  HBASE-22357 Fixed remaining Checkstyle issues in 
hbase-replication
48f2144 is described below

commit 48f2144c733ff34e71eb294e22a83d671cc2b259
Author: Jan Hentschel <jan.hentsc...@ultratendency.com>
AuthorDate: Fri May 3 13:02:53 2019 +0200

    HBASE-22357 Fixed remaining Checkstyle issues in hbase-replication
---
 .../hadoop/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 68f2adc..3854753 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<ZKUtilOp> 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);