diff --git a/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 b/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 index 09d9e2b9f28..15c5b700879 100644 --- a/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 +++ b/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()), -1); } if (!zkManager.exists(confStorePath)) { - zkManager.create(confStorePath); + zkManager.create(confStorePath, zkAcl); HashMap mapSchedConf = new HashMap<>(); for (Map.Entry entry : schedConf) { mapSchedConf.put(entry.getKey(), entry.getValue());