[FLINK-23361] when cleanup ZooKeeper Paths, high-availability.zookeeper.path.root doesn't work

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.13.1
• Fix Version/s: 1.13.1
• Component/s: flink-contrib
• Labels: security

Environment

Flink 1.13.1

• Release Note: flink 1.13.1
• Flags: Patch

Language

Java

• Assignee: Unassigned
• Reporter: shouzuo meng
• Created: 12/Jul/21 11:33
• Updated: 13/Jul/21 04:21

Description

When  I use "high-availability.zookeeper.path.root",

but execute tryDeleteEmptyParentZNodes, it doesn't work,It is possible that there is a problem in org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperHaServices#isRootPath

 

   private void tryDeleteEmptyParentZNodes() throws Exception {
        // try to delete the parent znodes if they are empty
        String remainingPath = 
                        getParentPath(getNormalizedPath(client.getNamespace()));       
final CuratorFramework nonNamespaceClient = client.usingNamespace(null);
        
        while (!isRootPath(remainingPath)) {
            try {
                nonNamespaceClient.delete().forPath(remainingPath);
            } catch (KeeperException.NotEmptyException ignored) {
                // We can only delete empty znodes
                break;
            }            remainingPath = getParentPath(remainingPath);
        }
    }

 

private static boolean isRootPath(String remainingPath) {
     return ZKPaths.PATH_SEPARATOR.equals(remainingPath);
 }

when i use "high-availability.zookeeper.path.root" , remainingPath should equals the root path that I specified