ACCUMULO-3167 Make sure to clean up before testBulkIngest runs
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/a4d62343 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/a4d62343 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/a4d62343 Branch: refs/heads/metrics2 Commit: a4d623430aa71d4daf43715167a91f89b39a682e Parents: e9fb8d0 Author: Josh Elser <[email protected]> Authored: Mon Nov 24 23:30:59 2014 -0500 Committer: Josh Elser <[email protected]> Committed: Mon Nov 24 23:30:59 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/accumulo/test/functional/ExamplesIT.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/a4d62343/test/src/test/java/org/apache/accumulo/test/functional/ExamplesIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/functional/ExamplesIT.java b/test/src/test/java/org/apache/accumulo/test/functional/ExamplesIT.java index fbaf243..5bced81 100644 --- a/test/src/test/java/org/apache/accumulo/test/functional/ExamplesIT.java +++ b/test/src/test/java/org/apache/accumulo/test/functional/ExamplesIT.java @@ -345,6 +345,11 @@ public class ExamplesIT extends AccumuloClusterIT { @Test public void testBulkIngest() throws Exception { String tableName = getUniqueNames(1)[0]; + FileSystem fs = getFileSystem(); + Path p = new Path(dir, "tmp"); + if (fs.exists(p)) { + fs.delete(p, true); + } goodExec(GenerateTestData.class, "--start-row", "0", "--count", "10000", "--output", dir + "/tmp/input/data"); goodExec(SetupTable.class, "-i", instance, "-z", keepers, "-u", user, "-p", passwd, "--table", tableName); goodExec(BulkIngestExample.class, "-i", instance, "-z", keepers, "-u", user, "-p", passwd, "--table", tableName, "--inputDir", dir + "/tmp/input",
