diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index 42569de..6fe0fd8 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -3410,9 +3410,11 @@ public static boolean createDirsWithPermission(Configuration conf, Path mkdir, return createDirsWithPermission(conf, mkdir, fsPermission, recursive); } - public static boolean createDirsWithPermission(Configuration conf, Path mkdir, + public static boolean createDirsWithPermission(Configuration conf, Path mkdirPath, FsPermission fsPermission, boolean recursive) throws IOException { String origUmask = null; + LOG.info("Create dirs " + mkdirPath + " with permission " + fsPermission + " recursive " + + recursive); if (recursive) { origUmask = conf.get("fs.permissions.umask-mode"); @@ -3421,9 +3423,8 @@ public static boolean createDirsWithPermission(Configuration conf, Path mkdir, conf.set("fs.permissions.umask-mode", "000"); } - FileSystem fs = mkdir.getFileSystem(conf); - boolean retval = fs.mkdirs(mkdir, fsPermission); - + FileSystem fs = FileSystem.newInstance(conf); + boolean retval = fs.mkdirs(mkdirPath, fsPermission); if (recursive) { if (origUmask != null) { conf.set("fs.permissions.umask-mode", origUmask);