Log creating the prepare/active barrier
@@ -111,6 +111,7 @@ class CuratorCompletionWaiter implements Curator.CompletionWaiter {
public static Curator.CompletionWaiter createAndInitialize(Curator curator, Path parentPath, String waiterNode, String id) {
Path waiterPath = parentPath.append(waiterNode);
+ log.fine("Recreating ZK path: " + waiterPath);
curator.delete(waiterPath);
curator.createAtomically(waiterPath);
return new CuratorCompletionWaiter(curator, waiterPath.getAbsolute(), id, Clock.systemUTC());
