You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by ja...@apache.org on 2019/06/09 22:06:40 UTC
[hbase] branch master updated: HBASE-22357 Fixed remaining
Checkstyle issues in hbase-replication
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 <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);