You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by vi...@apache.org on 2014/10/08 19:47:36 UTC
git commit: Changed checkpoint logging from LOG(INFO) to VLOG(1).
Repository: mesos
Updated Branches:
refs/heads/vinod/executor_workdir_log [created] 7c7f8dd19
Changed checkpoint logging from LOG(INFO) to VLOG(1).
Review: https://reviews.apache.org/r/26242
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/7c7f8dd1
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/7c7f8dd1
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/7c7f8dd1
Branch: refs/heads/vinod/executor_workdir_log
Commit: 7c7f8dd1996abed8ee046d013dda85e70e87f843
Parents: f95c42a
Author: Vinod Kone <vi...@gmail.com>
Authored: Wed Oct 1 12:05:57 2014 -0700
Committer: Vinod Kone <vi...@gmail.com>
Committed: Wed Oct 8 10:47:13 2014 -0700
----------------------------------------------------------------------
src/slave/slave.cpp | 24 ++++++++++++++----------
1 file changed, 14 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/7c7f8dd1/src/slave/slave.cpp
----------------------------------------------------------------------
diff --git a/src/slave/slave.cpp b/src/slave/slave.cpp
index e56dcbd..853c350 100644
--- a/src/slave/slave.cpp
+++ b/src/slave/slave.cpp
@@ -773,7 +773,7 @@ void Slave::registered(const UPID& from, const SlaveID& slaveId)
// Checkpoint slave info.
const string& path = paths::getSlaveInfoPath(metaDir, slaveId);
- LOG(INFO) << "Checkpointing SlaveInfo to '" << path << "'";
+ VLOG(1) << "Checkpointing SlaveInfo to '" << path << "'";
CHECK_SOME(state::checkpoint(path, info));
}
@@ -1611,8 +1611,8 @@ void Slave::updateFramework(const FrameworkID& frameworkId, const string& pid)
const string& path = paths::getFrameworkPidPath(
metaDir, info.id(), frameworkId);
- LOG(INFO) << "Checkpointing framework pid '"
- << framework->pid << "' to '" << path << "'";
+ VLOG(1) << "Checkpointing framework pid '"
+ << framework->pid << "' to '" << path << "'";
CHECK_SOME(state::checkpoint(path, framework->pid));
}
@@ -1839,8 +1839,8 @@ void Slave::registerExecutor(
executor->id,
executor->containerId);
- LOG(INFO) << "Checkpointing executor pid '"
- << executor->pid << "' to '" << path << "'";
+ VLOG(1) << "Checkpointing executor pid '"
+ << executor->pid << "' to '" << path << "'";
CHECK_SOME(state::checkpoint(path, executor->pid));
}
@@ -3617,15 +3617,15 @@ Framework::Framework(
string path = paths::getFrameworkInfoPath(
slave->metaDir, slave->info.id(), id);
- LOG(INFO) << "Checkpointing FrameworkInfo to '" << path << "'";
+ VLOG(1) << "Checkpointing FrameworkInfo to '" << path << "'";
CHECK_SOME(state::checkpoint(path, info));
// Checkpoint the framework pid.
path = paths::getFrameworkPidPath(
slave->metaDir, slave->info.id(), id);
- LOG(INFO) << "Checkpointing framework pid '"
- << pid << "' to '" << path << "'";
+ VLOG(1) << "Checkpointing framework pid '"
+ << pid << "' to '" << path << "'";
CHECK_SOME(state::checkpoint(path, pid));
}
}
@@ -3668,6 +3668,10 @@ Executor* Framework::launchExecutor(
executors[executorInfo.executor_id()] = executor;
+ LOG(INFO) << "Launching executor " << executorInfo.executor_id()
+ << " of framework " << id
+ << " in work directory '" << directory << "'";
+
slave->files->attach(executor->directory, executor->directory)
.onAny(defer(slave,
&Slave::fileAttached,
@@ -3940,7 +3944,7 @@ Executor::Executor(
const string& path = paths::getExecutorInfoPath(
slave->metaDir, slave->info.id(), frameworkId, id);
- LOG(INFO) << "Checkpointing ExecutorInfo to '" << path << "'";
+ VLOG(1) << "Checkpointing ExecutorInfo to '" << path << "'";
CHECK_SOME(state::checkpoint(path, info));
// Create the meta executor directory.
@@ -4050,7 +4054,7 @@ void Executor::checkpointTask(const TaskInfo& task)
containerId,
t.task_id());
- LOG(INFO) << "Checkpointing TaskInfo to '" << path << "'";
+ VLOG(1) << "Checkpointing TaskInfo to '" << path << "'";
CHECK_SOME(state::checkpoint(path, t));
}
}