|
@@ -52,7 +52,8 @@ public class MiniQJMHACluster {
|
|
|
private final Configuration conf;
|
|
|
private StartupOption startOpt = null;
|
|
|
private final MiniDFSCluster.Builder dfsBuilder;
|
|
|
-
|
|
|
+ private String baseDir;
|
|
|
+
|
|
|
public Builder(Configuration conf) {
|
|
|
this.conf = conf;
|
|
|
// most QJMHACluster tests don't need DataNodes, so we'll make
|
|
@@ -71,6 +72,11 @@ public class MiniQJMHACluster {
|
|
|
public void startupOption(StartupOption startOpt) {
|
|
|
this.startOpt = startOpt;
|
|
|
}
|
|
|
+
|
|
|
+ public Builder baseDir(String d) {
|
|
|
+ this.baseDir = d;
|
|
|
+ return this;
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
public static MiniDFSNNTopology createDefaultTopology(int basePort) {
|
|
@@ -92,8 +98,8 @@ public class MiniQJMHACluster {
|
|
|
basePort = 10000 + RANDOM.nextInt(1000) * 4;
|
|
|
LOG.info("Set MiniQJMHACluster basePort to " + basePort);
|
|
|
// start 3 journal nodes
|
|
|
- journalCluster = new MiniJournalCluster.Builder(conf).format(true)
|
|
|
- .build();
|
|
|
+ journalCluster = new MiniJournalCluster.Builder(conf)
|
|
|
+ .baseDir(builder.baseDir).format(true).build();
|
|
|
journalCluster.waitActive();
|
|
|
URI journalURI = journalCluster.getQuorumJournalURI(NAMESERVICE);
|
|
|
|