Repository: accumulo Updated Branches: refs/heads/1.6.0-SNAPSHOT 1d396489d -> b23408fae
ACCUMULO-2406 make GarbageCollectorIT use RawLocalFileSystem so walog writes are not lost Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/b23408fa Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/b23408fa Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/b23408fa Branch: refs/heads/1.6.0-SNAPSHOT Commit: b23408faea79a9839cbb39932004254229beac79 Parents: 1d39648 Author: Keith Turner <ktur...@apache.org> Authored: Tue Feb 25 16:14:57 2014 -0500 Committer: Keith Turner <ktur...@apache.org> Committed: Tue Feb 25 16:14:57 2014 -0500 ---------------------------------------------------------------------- .../org/apache/accumulo/test/functional/GarbageCollectorIT.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/b23408fa/test/src/test/java/org/apache/accumulo/test/functional/GarbageCollectorIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/functional/GarbageCollectorIT.java b/test/src/test/java/org/apache/accumulo/test/functional/GarbageCollectorIT.java index 6f9b926..887e55a 100644 --- a/test/src/test/java/org/apache/accumulo/test/functional/GarbageCollectorIT.java +++ b/test/src/test/java/org/apache/accumulo/test/functional/GarbageCollectorIT.java @@ -60,6 +60,7 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; +import org.apache.hadoop.fs.RawLocalFileSystem; import org.apache.hadoop.io.Text; import org.apache.zookeeper.KeeperException; import org.apache.zookeeper.KeeperException.NoNodeException; @@ -79,6 +80,9 @@ public class GarbageCollectorIT extends ConfigurableMacIT { settings.put(Property.TSERV_MAXMEM.getKey(), "5K"); settings.put(Property.TSERV_MAJC_DELAY.getKey(), "1"); cfg.setSiteConfig(settings); + + // use raw local file system so walogs sync and flush will work + hadoopCoreSite.set("fs.file.impl", RawLocalFileSystem.class.getName()); } private void killMacGc() throws ProcessNotFoundException, InterruptedException, KeeperException {
