hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [hbase] branch master updated: HBASE-22357 Fixed remaining Checkstyle issues in hbase-replication
Date Sun, 09 Jun 2019 22:06:40 GMT
This is an automated email from the ASF dual-hosted git repository.

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


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

commit e8ef8ad42f535131a5866704635c36edbd8db8b0
Author: Jan Hentschel <jan.hentschel@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);


Mime
View raw message