update

server/worker.go

@@ -141,9 +141,18 @@ func (w *Worker) doGoodBye(msg *omanager.WorkerMessage_GoodbyeMessage) {
 }
 
 func (w *Worker) doSubmitAck(msg *omanager.WorkerMessage_SubmitTaskAck) {
+	log.WithFields(log.Fields{
+		"worker-addr": w.workerAddr,
+		"task-id":     msg.SubmitTaskAck.TaskId,
+	}).Debug("receive worker submit task ack")
 	if v, ok := w.recentTask.Get(msg.SubmitTaskAck.TaskId); ok {
 		dtask := v.(*dispatchTask)
 		dtask.setAck(msg.SubmitTaskAck)
+	} else {
+		log.WithFields(log.Fields{
+			"worker-addr": w.workerAddr,
+			"task-id":     msg.SubmitTaskAck.TaskId,
+		}).Warn("ack not found task")
 	}
 }