SAMOA-28: Delete samoa-api/build directory after tests
Project: http://git-wip-us.apache.org/repos/asf/incubator-samoa/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-samoa/commit/1bf3c027 Tree: http://git-wip-us.apache.org/repos/asf/incubator-samoa/tree/1bf3c027 Diff: http://git-wip-us.apache.org/repos/asf/incubator-samoa/diff/1bf3c027 Branch: refs/heads/master Commit: 1bf3c0270d759dec3bd6649e0418dc4e4cd509e7 Parents: c1d42d2 Author: Gianmarco De Francisci Morales <[email protected]> Authored: Sun Mar 6 16:15:58 2016 +0300 Committer: Gianmarco De Francisci Morales <[email protected]> Committed: Sun Mar 13 11:02:20 2016 +0300 ---------------------------------------------------------------------- .../streams/fs/HDFSFileStreamSourceTest.java | 24 ++++++++------------ 1 file changed, 10 insertions(+), 14 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-samoa/blob/1bf3c027/samoa-api/src/test/java/org/apache/samoa/streams/fs/HDFSFileStreamSourceTest.java ---------------------------------------------------------------------- diff --git a/samoa-api/src/test/java/org/apache/samoa/streams/fs/HDFSFileStreamSourceTest.java b/samoa-api/src/test/java/org/apache/samoa/streams/fs/HDFSFileStreamSourceTest.java index eaba37d..f6846cd 100644 --- a/samoa-api/src/test/java/org/apache/samoa/streams/fs/HDFSFileStreamSourceTest.java +++ b/samoa-api/src/test/java/org/apache/samoa/streams/fs/HDFSFileStreamSourceTest.java @@ -1,5 +1,9 @@ package org.apache.samoa.streams.fs; +import static org.junit.Assert.*; + +import java.io.BufferedReader; + /* * #%L * SAMOA @@ -21,29 +25,20 @@ package org.apache.samoa.streams.fs; */ import java.io.BufferedWriter; -import java.io.BufferedReader; -import java.io.File; +import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; -import java.io.IOException; import java.io.OutputStream; import java.io.OutputStreamWriter; +import java.util.HashSet; import java.util.Iterator; import java.util.Set; -import java.util.HashSet; import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.hdfs.MiniDFSCluster; -import org.apache.hadoop.hdfs.MiniDFSCluster.Builder; import org.apache.hadoop.fs.FileSystem; -import org.apache.hadoop.fs.FSDataOutputStream; import org.apache.hadoop.fs.Path; -import org.apache.samoa.streams.fs.HDFSFileStreamSource; - -import static org.junit.Assert.*; - +import org.apache.hadoop.hdfs.MiniDFSCluster; import org.junit.After; -import org.junit.Assert; import org.junit.Before; import org.junit.Test; @@ -63,7 +58,9 @@ public class HDFSFileStreamSourceTest { @Before public void setUp() throws Exception { // Start MiniDFSCluster - MiniDFSCluster.Builder builder = new MiniDFSCluster.Builder(new Configuration()).hosts(HOSTS).numDataNodes(1) + config = new Configuration(); + config.set("hdfs.minidfs.basedir", "target/build/test/data/dfs"); + MiniDFSCluster.Builder builder = new MiniDFSCluster.Builder(config).hosts(HOSTS).numDataNodes(1) .format(true); hdfsCluster = builder.build(); hdfsCluster.waitActive(); @@ -73,7 +70,6 @@ public class HDFSFileStreamSourceTest { streamSource = new HDFSFileStreamSource(); // General config - config = new Configuration(); config.set("fs.defaultFS", hdfsURI); }
