You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by iw...@apache.org on 2022/05/24 05:25:22 UTC

[hadoop] branch branch-3.2 updated: YARN-11162. Set the zk acl for nodes created by ZKConfigurationStore. (#4350)

This is an automated email from the ASF dual-hosted git repository.

iwasakims pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/branch-3.2 by this push:
     new 2113c842608 YARN-11162. Set the zk acl for nodes created by ZKConfigurationStore. (#4350)
2113c842608 is described below

commit 2113c8426081b7c106398a5d14c690c470104670
Author: Owen O'Malley <oo...@linkedin.com>
AuthorDate: Mon May 23 22:07:19 2022 -0700

    YARN-11162. Set the zk acl for nodes created by ZKConfigurationStore. (#4350)
    
    (cherry picked from commit f390edaec44cfa91b2b09549091f033f1749d8ac)
---
 .../resourcemanager/scheduler/capacity/conf/ZKConfigurationStore.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 cacf32b3911..c05729d576a 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
@@ -254,7 +254,7 @@ public class ZKConfigurationStore extends YarnConfigurationStore {
   private boolean createNewZkPath(String path) throws Exception {
     if (!zkManager.exists(path)) {
       try {
-        zkManager.create(path);
+        zkManager.create(path, zkAcl);
       } catch(NodeExistsException e) {
         LOG.warn(NODEEXISTS_MSG, e);
         return false;


---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org