Skip to content

Commit

Permalink
#298 - updated datadir to use directory in target/
Browse files Browse the repository at this point in the history
  • Loading branch information
mikewalch committed Nov 12, 2014
1 parent 1290086 commit fcdd606
Showing 1 changed file with 9 additions and 4 deletions.
13 changes: 9 additions & 4 deletions modules/core/src/test/java/io/fluo/core/impl/MiniIT.java
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

import java.io.File;

import com.google.common.io.Files;
import io.fluo.api.client.FluoClient;
import io.fluo.api.client.FluoFactory;
import io.fluo.api.client.Snapshot;
Expand All @@ -26,6 +25,7 @@
import io.fluo.api.data.Bytes;
import io.fluo.api.data.Column;
import io.fluo.api.mini.MiniFluo;
import io.fluo.core.util.PortUtils;
import org.apache.commons.io.FileUtils;
import org.junit.Assert;
import org.junit.Test;
Expand All @@ -37,11 +37,16 @@ public class MiniIT {

@Test
public void testMini() throws Exception {
File tempDir = Files.createTempDir();
File dataDir = new File(System.getProperty("user.dir") + "/target/"+MiniIT.class.getSimpleName());
if (dataDir.exists()) {
FileUtils.deleteDirectory(dataDir);
}
dataDir.mkdirs();
try {
FluoConfiguration config = new FluoConfiguration();
config.setMiniDataDir(tempDir.getAbsolutePath());
config.setMiniDataDir(dataDir.getAbsolutePath());
config.setMiniStartAccumulo(true);
config.setOraclePort(PortUtils.getRandomFreePort());
try (MiniFluo mini = FluoFactory.newMiniFluo(config)) {
try (FluoClient client = FluoFactory.newClient(mini.getClientConfiguration())) {
Assert.assertNotNull(client);
Expand All @@ -60,7 +65,7 @@ public void testMini() throws Exception {
}
}
} finally {
FileUtils.deleteDirectory(tempDir);
FileUtils.deleteDirectory(dataDir);
}
}
}

0 comments on commit fcdd606

Please sign in to comment.