Browse Source

YARN-11162. Set the zk acl for nodes created by ZKConfigurationStore. (#4350)

(cherry picked from commit f390edaec44cfa91b2b09549091f033f1749d8ac)

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 88a8752fa2ba0c70b0df94a78eb9fd86b965acd5)
Owen O'Malley 2 years ago
parent
commit
227d64ab59

+ 2 - 2
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

@@ -97,13 +97,13 @@ public class ZKConfigurationStore extends YarnConfigurationStore {
     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());