YARN-11162. Set the zk acl for nodes created by ZKConfigurationStore. (…

…#4350) (cherry picked from commit f390eda) Conflicts: hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/conf/ZKConfigurationStore.java (cherry picked from commit 88a8752)
apache · May 24, 2022 · 227d64a · 227d64a
1 parent ba041fe
commit 227d64a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ache/hadoop/yarn/server/resourcemanager/scheduler/capacity/conf/ZKConfigurationStore.java b/...ache/hadoop/yarn/server/resourcemanager/scheduler/capacity/conf/ZKConfigurationStore.java
@@ -97,13 +97,13 @@ public void initialize(Configuration config, Configuration schedConf,
     zkManager.delete(fencingNodePath);
 
     if (!zkManager.exists(logsPath)) {
-      zkManager.create(logsPath);
+      zkManager.create(logsPath, zkAcl);
       zkManager.setData(logsPath,
           serializeObject(new LinkedList<LogMutation>()), -1);
     }
 
     if (!zkManager.exists(confStorePath)) {
-      zkManager.create(confStorePath);
+      zkManager.create(confStorePath, zkAcl);
       HashMap<String, String> mapSchedConf = new HashMap<>();
       for (Map.Entry<String, String> entry : schedConf) {
         mapSchedConf.put(entry.getKey(), entry.getValue());