Skip to content
Permalink
Browse files
GIRAPH-1164
closes #53
  • Loading branch information
dlogothetis authored and Maja Kabiljo committed Nov 3, 2017
1 parent 2e7ce47 commit dc500a7adffbb3cf94604097efe1eb93bc43822d
Showing 1 changed file with 6 additions and 0 deletions.
@@ -163,6 +163,7 @@ public static Iterable<String> run(
File outputDir = FileUtils.createTempDir(tmpDir, "output");
File zkDir = FileUtils.createTempDir(tmpDir, "_bspZooKeeper");
File zkMgrDir = FileUtils.createTempDir(tmpDir, "_defaultZkManagerDir");
File mrLocalDir = FileUtils.createTempDir(tmpDir, "_mapred");
// Write input data to disk
if (conf.hasVertexInputFormat()) {
FileUtils.writeLines(vertexInputFile, vertexInputData);
@@ -174,6 +175,8 @@ public static Iterable<String> run(
conf.setWorkerConfiguration(1, 1, 100.0f);
GiraphConstants.SPLIT_MASTER_WORKER.set(conf, false);
GiraphConstants.LOCAL_TEST_MODE.set(conf, true);
conf.setIfUnset("mapred.job.tracker", "local");
conf.setIfUnset("mapred.local.dir", mrLocalDir.toString());

conf.set(GiraphConstants.ZOOKEEPER_DIR, zkDir.toString());
GiraphConstants.ZOOKEEPER_MANAGER_DIRECTORY.set(conf,
@@ -267,6 +270,7 @@ E extends Writable> void run(
String checkpointsDir) throws Exception {
File zkDir = FileUtils.createTempDir(tmpDir, "_bspZooKeeper");
File zkMgrDir = FileUtils.createTempDir(tmpDir, "_defaultZkManagerDir");
File mrLocalDir = FileUtils.createTempDir(tmpDir, "_mapred");

if (checkpointsDir == null) {
checkpointsDir = FileUtils.
@@ -284,6 +288,8 @@ E extends Writable> void run(
GiraphConstants.SPLIT_MASTER_WORKER.set(conf, false);
GiraphConstants.LOCAL_TEST_MODE.set(conf, true);
GiraphConstants.ZOOKEEPER_SERVER_PORT.set(conf, 0);
conf.setIfUnset("mapred.job.tracker", "local");
conf.setIfUnset("mapred.local.dir", mrLocalDir.toString());

conf.set(GiraphConstants.ZOOKEEPER_DIR, zkDir.toString());
GiraphConstants.ZOOKEEPER_MANAGER_DIRECTORY.set(conf,

0 comments on commit dc500a7

Please sign in to comment.