HADOOP-9289. Merge 1443108 from trunk
git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/branches/branch-2@1443127 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
dcbad333ad
commit
7aed4100d9
|
@ -301,6 +301,9 @@ Release 2.0.3-alpha - 2013-02-06
|
||||||
HADOOP-9278. Fix the file handle leak in HarMetaData.parseMetaData() in
|
HADOOP-9278. Fix the file handle leak in HarMetaData.parseMetaData() in
|
||||||
HarFileSystem. (Chris Nauroth via szetszwo)
|
HarFileSystem. (Chris Nauroth via szetszwo)
|
||||||
|
|
||||||
|
HADOOP-9289. FsShell rm -f fails for non-matching globs. (Daryn Sharp via
|
||||||
|
suresh)
|
||||||
|
|
||||||
Release 2.0.2-alpha - 2012-09-07
|
Release 2.0.2-alpha - 2012-09-07
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -21,6 +21,7 @@ package org.apache.hadoop.fs.shell;
|
||||||
import java.io.FileNotFoundException;
|
import java.io.FileNotFoundException;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.util.LinkedList;
|
import java.util.LinkedList;
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
import org.apache.hadoop.classification.InterfaceAudience;
|
import org.apache.hadoop.classification.InterfaceAudience;
|
||||||
import org.apache.hadoop.classification.InterfaceStability;
|
import org.apache.hadoop.classification.InterfaceStability;
|
||||||
|
@ -28,6 +29,7 @@ import org.apache.hadoop.fs.PathIOException;
|
||||||
import org.apache.hadoop.fs.PathIsDirectoryException;
|
import org.apache.hadoop.fs.PathIsDirectoryException;
|
||||||
import org.apache.hadoop.fs.PathIsNotDirectoryException;
|
import org.apache.hadoop.fs.PathIsNotDirectoryException;
|
||||||
import org.apache.hadoop.fs.PathIsNotEmptyDirectoryException;
|
import org.apache.hadoop.fs.PathIsNotEmptyDirectoryException;
|
||||||
|
import org.apache.hadoop.fs.PathNotFoundException;
|
||||||
import org.apache.hadoop.fs.Trash;
|
import org.apache.hadoop.fs.Trash;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
@ -71,6 +73,19 @@ class Delete {
|
||||||
skipTrash = cf.getOpt("skipTrash");
|
skipTrash = cf.getOpt("skipTrash");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
protected List<PathData> expandArgument(String arg) throws IOException {
|
||||||
|
try {
|
||||||
|
return super.expandArgument(arg);
|
||||||
|
} catch (PathNotFoundException e) {
|
||||||
|
if (!ignoreFNF) {
|
||||||
|
throw e;
|
||||||
|
}
|
||||||
|
// prevent -f on a non-existent glob from failing
|
||||||
|
return new LinkedList<PathData>();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected void processNonexistentPath(PathData item) throws IOException {
|
protected void processNonexistentPath(PathData item) throws IOException {
|
||||||
if (!ignoreFNF) super.processNonexistentPath(item);
|
if (!ignoreFNF) super.processNonexistentPath(item);
|
||||||
|
|
|
@ -299,6 +299,46 @@ public class TestFsShellReturnCode {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testRmWithNonexistentGlob() throws Exception {
|
||||||
|
Configuration conf = new Configuration();
|
||||||
|
FsShell shell = new FsShell();
|
||||||
|
shell.setConf(conf);
|
||||||
|
final ByteArrayOutputStream bytes = new ByteArrayOutputStream();
|
||||||
|
final PrintStream err = new PrintStream(bytes);
|
||||||
|
final PrintStream oldErr = System.err;
|
||||||
|
System.setErr(err);
|
||||||
|
final String results;
|
||||||
|
try {
|
||||||
|
int exit = shell.run(new String[]{"-rm", "nomatch*"});
|
||||||
|
assertEquals(1, exit);
|
||||||
|
results = bytes.toString();
|
||||||
|
assertTrue(results.contains("rm: `nomatch*': No such file or directory"));
|
||||||
|
} finally {
|
||||||
|
IOUtils.closeStream(err);
|
||||||
|
System.setErr(oldErr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
@Test
|
||||||
|
public void testRmForceWithNonexistentGlob() throws Exception {
|
||||||
|
Configuration conf = new Configuration();
|
||||||
|
FsShell shell = new FsShell();
|
||||||
|
shell.setConf(conf);
|
||||||
|
final ByteArrayOutputStream bytes = new ByteArrayOutputStream();
|
||||||
|
final PrintStream err = new PrintStream(bytes);
|
||||||
|
final PrintStream oldErr = System.err;
|
||||||
|
System.setErr(err);
|
||||||
|
try {
|
||||||
|
int exit = shell.run(new String[]{"-rm", "-f", "nomatch*"});
|
||||||
|
assertEquals(0, exit);
|
||||||
|
assertTrue(bytes.toString().isEmpty());
|
||||||
|
} finally {
|
||||||
|
IOUtils.closeStream(err);
|
||||||
|
System.setErr(oldErr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
@Test
|
@Test
|
||||||
public void testInvalidDefaultFS() throws Exception {
|
public void testInvalidDefaultFS() throws Exception {
|
||||||
// if default fs doesn't exist or is invalid, but the path provided in
|
// if default fs doesn't exist or is invalid, but the path provided in
|
||||||
|
|
Loading…
Reference in New Issue