github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 06:27:05 +00:00
Code Issues Projects Releases Wiki Activity

Log Mesos task message on status update

Browse Source 
- Log error when task state is unknown
This commit is contained in:
Karl Isenberg 2015-08-24 13:21:17 -07:00
parent f9635d5778
commit 158c42f4be
1 changed files with 20 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
contrib/mesos/pkg/scheduler/scheduler.go
View File

@ -400,14 +400,21 @@ func (k *KubernetesScheduler) StatusUpdate(driver bindings.SchedulerDriver, task
taskState := taskStatus.GetState() taskState := taskStatus.GetState()
metrics.StatusUpdates.WithLabelValues(source, reason, taskState.String()).Inc() metrics.StatusUpdates.WithLabelValues(source, reason, taskState.String()).Inc()
message := "none"
if taskStatus.Message != nil {
message = *taskStatus.Message
}
log.Infof( log.Infof(
"task status update %q from %q for task %q on slave %q executor %q for reason %q", "task status update %q from %q for task %q on slave %q executor %q for reason %q with message %q",
taskState.String(), taskState.String(),
source, source,
taskStatus.TaskId.GetValue(), taskStatus.TaskId.GetValue(),
taskStatus.SlaveId.GetValue(), taskStatus.SlaveId.GetValue(),
taskStatus.ExecutorId.GetValue(), taskStatus.ExecutorId.GetValue(),
reason) reason,
message,
)
switch taskState { switch taskState {
case mesos.TaskState_TASK_RUNNING, mesos.TaskState_TASK_FINISHED, mesos.TaskState_TASK_STARTING, mesos.TaskState_TASK_STAGING: case mesos.TaskState_TASK_RUNNING, mesos.TaskState_TASK_FINISHED, mesos.TaskState_TASK_STARTING, mesos.TaskState_TASK_STAGING:
@ -443,6 +450,17 @@ func (k *KubernetesScheduler) StatusUpdate(driver bindings.SchedulerDriver, task
fallthrough fallthrough
case mesos.TaskState_TASK_LOST, mesos.TaskState_TASK_KILLED: case mesos.TaskState_TASK_LOST, mesos.TaskState_TASK_KILLED:
k.reconcileTerminalTask(driver, taskStatus) k.reconcileTerminalTask(driver, taskStatus)
default:
log.Errorf(
"unknown task status %q from %q for task %q on slave %q executor %q for reason %q with message %q",
taskState.String(),
source,
taskStatus.TaskId.GetValue(),
taskStatus.SlaveId.GetValue(),
taskStatus.ExecutorId.GetValue(),
reason,
message,
)
} }
} }