diff --git a/go/master/client.go b/go/master/client.go
index 6f06fd04218999035e6791f498e1ec433dfe8199..59bac6874c9bcdc9a7717931d1d27bcaa0f31780 100644
--- a/go/master/client.go
+++ b/go/master/client.go
@@ -114,7 +114,7 @@ func (c *Client) taskFinished(taskID int) error {
 
 // TaskFailed tell the master server as task is failed.
 func (c *Client) taskFailed(meta TaskMeta) error {
-	return c.conn.Call("Service.TaskFinished", meta, nil)
+	return c.conn.Call("Service.TaskFailed", meta, nil)
 }
 
 // NextRecord returns next record in the dataset.
diff --git a/go/master/client_internal_test.go b/go/master/client_internal_test.go
index dc4d9eab14ea41ff361087d3580d0f28271b3868..49263474c8fe2410ffb6db93a9647f5ab066b06b 100644
--- a/go/master/client_internal_test.go
+++ b/go/master/client_internal_test.go
@@ -99,6 +99,12 @@ func TestGetFinishTask(t *testing.T) {
 		if err != nil {
 			t.Fatalf("Error: %v, pass: %d\n", err, i)
 		}
+
+		err = c.taskFailed(tasks[0].Meta)
+		if err != nil {
+			t.Fatalf("Error: %v, pass: %d\n", err, i)
+		}
+
 		tasks = tasks[1:]
 		task, err := c.getTask()
 		if err != nil {
diff --git a/go/master/service.go b/go/master/service.go
index 1291ac48f12575a4af2c62404a2c9dd8c4c47f40..a6050ab99437244dade83f2943f6649453d47fff 100644
--- a/go/master/service.go
+++ b/go/master/service.go
@@ -359,7 +359,7 @@ func (s *Service) GetTask(dummy int, task *Task) error {
 	}
 
 	*task = t.Task
-	log.WithFields(s.logFields()).Infof("Task #%v dispatched.", t.Meta)
+	log.WithFields(s.logFields()).Infof("Task #%v dispatched.", t.Task.Meta)
 
 	time.AfterFunc(s.timeoutDur, s.checkTimeoutFunc(t.Task.Meta.ID, t.Task.Meta.Epoch))
 	return nil
@@ -376,7 +376,6 @@ func (s *Service) TaskFinished(taskID int, dummy *int) error {
 
 	t, ok := s.taskQueues.Pending[taskID]
 	if !ok {
-		err := errors.New("pending task not found")
 		log.WithFields(s.logFields()).Warningln("Pending task #%d not found.", taskID)
 		return nil
 	}
@@ -412,8 +411,7 @@ func (s *Service) TaskFailed(meta TaskMeta, dummy *int) error {
 
 	t, ok := s.taskQueues.Pending[meta.ID]
 	if !ok {
-		err := errors.New("pending task not found")
-		log.WithFields(s.logFields()).Warningln("TaskFailed:Pending task #%v not found.", t.Meta)
+		log.WithFields(s.logFields()).Warningln("TaskFailed:Pending task #%v not found.", t.Task.Meta)
 		return nil
 	}