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

[ja...@apache.org]

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

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


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

commit 4fade3562096f836bbc5b783d78d00c55d1e84e0
Author: Jan Hentschel <ja...@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);