[accumulo] branch main updated: closes #1955 - move log message

[dl...@apache.org]

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

dlmarion pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/main by this push:
     new a77edef  closes #1955 - move log message
a77edef is described below

commit a77edef9a22fa662b78dce211be6c17f59d6060d
Author: Dave Marion <dl...@apache.org>
AuthorDate: Mon Mar 8 15:39:40 2021 -0500

    closes #1955 - move log message
    
    move renewed watcher log message to a point where we know the node exists (#1962)
---
 core/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java b/core/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java
index 02b089f..15ff591 100644
--- a/core/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java
+++ b/core/src/main/java/org/apache/accumulo/fate/zookeeper/ZooLock.java
@@ -348,7 +348,6 @@ public class ZooLock implements Watcher {
             renew = false;
           }
           if (renew) {
-            LOG.debug("[{}] Renewing watch on prior node  {}", vmLockPrefix, nodeToWatch);
             try {
               Stat restat = zooKeeper.exists(nodeToWatch, this);
               if (restat == null) {
@@ -357,6 +356,8 @@ public class ZooLock implements Watcher {
                 // created.
                 zooKeeper.removeWatches(nodeToWatch, this, WatcherType.Any, true);
                 determineLockOwnership(createdEphemeralNode, lw);
+              } else {
+                LOG.debug("[{}] Renewed watch on prior node  {}", vmLockPrefix, nodeToWatch);
               }
             } catch (KeeperException | InterruptedException e) {
               lw.failedToAcquireLock(new Exception("Failed to renew watch on other manager node"));