diff --git a/hadoop-common-project/hadoop-common/CHANGES.txt b/hadoop-common-project/hadoop-common/CHANGES.txt index eba60c1315..46251b14e3 100644 --- a/hadoop-common-project/hadoop-common/CHANGES.txt +++ b/hadoop-common-project/hadoop-common/CHANGES.txt @@ -290,8 +290,8 @@ Release 0.23.2 - UNRELEASED INCOMPATIBLE CHANGES - NEW FEATURES - + NEW FEATURES + IMPROVEMENTS HADOOP-8048. Allow merging of Credentials (Daryn Sharp via tgraves) @@ -305,7 +305,10 @@ Release 0.23.2 - UNRELEASED HADOOP-8137. Added links to CLI manuals to the site. (tgraves via acmurthy) + HADOOP-8175. FsShell: Add -p option to mkdir. (Daryn Sharp via szetszwo) + OPTIMIZATIONS + HADOOP-8071. Avoid an extra packet in client code when nagling is disabled. (todd) diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/shell/Mkdir.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/shell/Mkdir.java index 30ce5ed4df..2f2e4e59a4 100644 --- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/shell/Mkdir.java +++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/shell/Mkdir.java @@ -43,16 +43,21 @@ public static void registerCommands(CommandFactory factory) { public static final String DESCRIPTION = "Create a directory in specified location."; + private boolean createParents; + @Override protected void processOptions(LinkedList args) { - CommandFormat cf = new CommandFormat(1, Integer.MAX_VALUE); + CommandFormat cf = new CommandFormat(1, Integer.MAX_VALUE, "p"); cf.parse(args); + createParents = cf.getOpt("p"); } @Override protected void processPath(PathData item) throws IOException { if (item.stat.isDirectory()) { - throw new PathExistsException(item.toString()); + if (!createParents) { + throw new PathExistsException(item.toString()); + } } else { throw new PathIsNotDirectoryException(item.toString()); } @@ -60,6 +65,7 @@ protected void processPath(PathData item) throws IOException { @Override protected void processNonexistentPath(PathData item) throws IOException { + // TODO: should use createParents to control intermediate dir creation if (!item.fs.mkdirs(item.path)) { throw new PathIOException(item.toString()); }