You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by ji...@apache.org on 2015/04/10 23:57:02 UTC
[2/2] mesos git commit: Fixed a bug regarding setting work_dir for a
local cluster.
Fixed a bug regarding setting work_dir for a local cluster.
Review: https://reviews.apache.org/r/32983
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/2037099d
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/2037099d
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/2037099d
Branch: refs/heads/master
Commit: 2037099d6d95ef8d99d971e47cfd75968543d972
Parents: 743e9e7
Author: Jie Yu <yu...@gmail.com>
Authored: Wed Apr 8 11:32:28 2015 -0700
Committer: Jie Yu <yu...@gmail.com>
Committed: Fri Apr 10 14:56:36 2015 -0700
----------------------------------------------------------------------
src/local/local.cpp | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/2037099d/src/local/local.cpp
----------------------------------------------------------------------
diff --git a/src/local/local.cpp b/src/local/local.cpp
index 1908336..289b9bc 100644
--- a/src/local/local.cpp
+++ b/src/local/local.cpp
@@ -287,6 +287,9 @@ PID<Master> launch(const Flags& flags, Allocator* _allocator)
<< "slave flags from the environment: " << load.error();
}
+ // Use a different work directory for each slave.
+ flags.work_dir = path::join(flags.work_dir, stringify(i));
+
garbageCollectors->push_back(new GarbageCollector());
statusUpdateManagers->push_back(new StatusUpdateManager(flags));
fetchers->push_back(new Fetcher());
@@ -298,9 +301,6 @@ PID<Master> launch(const Flags& flags, Allocator* _allocator)
EXIT(1) << "Failed to create a containerizer: " << containerizer.error();
}
- // Use a different work directory for each slave.
- flags.work_dir = path::join(flags.work_dir, stringify(i));
-
// NOTE: At this point detector is already initialized by the
// Master.
Slave* slave = new Slave(