diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/zksyncer/ClientZKSyncer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/zksyncer/ClientZKSyncer.java index b1c70c5693..e4c13c11ed 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/zksyncer/ClientZKSyncer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/zksyncer/ClientZKSyncer.java @@ -65,13 +65,13 @@ public abstract class ClientZKSyncer extends ZKListener { * @throws KeeperException if error occurs when trying to create base nodes on client ZK */ public void start() throws KeeperException { - LOG.debug("Starting " + getClass().getSimpleName()); + LOG.debug("Starting {}", getClass().getSimpleName()); this.watcher.registerListener(this); // create base znode on remote ZK ZKUtil.createWithParents(clientZkWatcher, watcher.getZNodePaths().baseZNode); // set meta znodes for client ZK Collection nodes = getNodesToWatch(); - LOG.debug("Znodes to watch: " + nodes); + LOG.debug("Znodes to watch: {}", nodes); // initialize queues and threads for (String node : nodes) { BlockingQueue queue = new ArrayBlockingQueue<>(1); @@ -92,7 +92,7 @@ public abstract class ClientZKSyncer extends ZKListener { upsertQueue(node, data); } else { // It existed but now does not, should has been tracked by our watcher, ignore - LOG.debug("Found no data from " + node); + LOG.debug("Found no data from {}", node); watchAndCheckExists(node); } } else { @@ -130,7 +130,7 @@ public abstract class ClientZKSyncer extends ZKListener { throws InterruptedException { while (!server.isStopped()) { try { - LOG.debug("Set data for remote " + node + ", client zk wather: " + clientZkWatcher); + LOG.debug("Set data for remote {}, client zk wather: {}", node, clientZkWatcher); ZKUtil.setData(clientZkWatcher, node, data); break; } catch (KeeperException.NoNodeException nne) { @@ -229,10 +229,7 @@ public abstract class ClientZKSyncer extends ZKListener { byte[] data = queue.take(); setDataForClientZkUntilSuccess(znode, data); } catch (InterruptedException e) { - if (LOG.isDebugEnabled()) { - LOG.debug( - "Interrupted while checking whether need to update meta location to client zk"); - } + LOG.debug("Interrupted while checking whether need to update meta location to client zk"); Thread.currentThread().interrupt(); break; }