ACCUMULO-2475 recovery failed due to using the wrong filesystem
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/ae750622 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/ae750622 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/ae750622 Branch: refs/heads/ACCUMULO-2061 Commit: ae750622c2baf4761afd9354540383f3b01ab6e2 Parents: 6dd1bd3 Author: Eric Newton <eric.new...@gmail.com> Authored: Fri Mar 14 12:55:32 2014 -0400 Committer: Eric Newton <eric.new...@gmail.com> Committed: Fri Mar 14 12:55:32 2014 -0400 ---------------------------------------------------------------------- .../org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/ae750622/test/src/test/java/org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java b/test/src/test/java/org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java index 86c5004..7cb1fe5 100644 --- a/test/src/test/java/org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java +++ b/test/src/test/java/org/apache/accumulo/test/MasterRepairsDualAssignmentIT.java @@ -46,6 +46,7 @@ import org.apache.accumulo.server.master.state.TabletLocationState; import org.apache.accumulo.test.functional.ConfigurableMacIT; import org.apache.accumulo.test.functional.FunctionalTestUtils; import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.fs.RawLocalFileSystem; import org.apache.hadoop.io.Text; import org.junit.Test; @@ -56,6 +57,8 @@ public class MasterRepairsDualAssignmentIT extends ConfigurableMacIT { public void configure(MiniAccumuloConfigImpl cfg, Configuration hadoopCoreSite) { cfg.setProperty(Property.INSTANCE_ZK_TIMEOUT, "5s"); cfg.setProperty(Property.MASTER_RECOVERY_DELAY, "5s"); + // use raw local file system so walogs sync and flush will work + hadoopCoreSite.set("fs.file.impl", RawLocalFileSystem.class.getName()); } @Test(timeout = 5 * 60 * 1000)
