Repository: accumulo Updated Branches: refs/heads/master 044e46df5 -> b0d1d291c
ACCUMULO-3871 use the correct filesystem Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b0d1d291 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b0d1d291 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b0d1d291 Branch: refs/heads/master Commit: b0d1d291c4a245351d27c31c7443f53d87094bc3 Parents: 044e46d Author: Eric Newton <eric.new...@gmail.com> Authored: Thu Jun 4 09:39:50 2015 -0400 Committer: Eric Newton <eric.new...@gmail.com> Committed: Thu Jun 4 09:39:50 2015 -0400 ---------------------------------------------------------------------- .../test/java/org/apache/accumulo/test/FileArchiveIT.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/b0d1d291/test/src/test/java/org/apache/accumulo/test/FileArchiveIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/FileArchiveIT.java b/test/src/test/java/org/apache/accumulo/test/FileArchiveIT.java index 2e45d80..390d20a 100644 --- a/test/src/test/java/org/apache/accumulo/test/FileArchiveIT.java +++ b/test/src/test/java/org/apache/accumulo/test/FileArchiveIT.java @@ -29,13 +29,11 @@ import org.apache.accumulo.core.data.Value; import org.apache.accumulo.core.metadata.MetadataTable; import org.apache.accumulo.core.metadata.schema.MetadataSchema; import org.apache.accumulo.core.security.Authorizations; -import org.apache.accumulo.core.util.CachedConfiguration; import org.apache.accumulo.minicluster.impl.MiniAccumuloConfigImpl; import org.apache.accumulo.server.ServerConstants; import org.apache.accumulo.test.functional.ConfigurableMacIT; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileSystem; -import org.apache.hadoop.fs.LocalFileSystem; import org.apache.hadoop.fs.Path; import org.junit.Assert; import org.junit.Test; @@ -91,7 +89,7 @@ public class FileArchiveIT extends ConfigurableMacIT { log.info("File for table: " + file); - FileSystem fs = LocalFileSystem.get(CachedConfiguration.getInstance()); + FileSystem fs = getCluster().getFileSystem(); int i = 0; while (fs.exists(p)) { i++; @@ -148,7 +146,7 @@ public class FileArchiveIT extends ConfigurableMacIT { log.info("File for table: " + file); - FileSystem fs = LocalFileSystem.get(CachedConfiguration.getInstance()); + FileSystem fs = getCluster().getFileSystem(); int i = 0; while (fs.exists(p)) { i++; @@ -206,7 +204,7 @@ public class FileArchiveIT extends ConfigurableMacIT { log.info("File for table: " + file); - FileSystem fs = LocalFileSystem.get(CachedConfiguration.getInstance()); + FileSystem fs = getCluster().getFileSystem(); int i = 0; while (fs.exists(p)) { i++;
