From e27a51f8844b1e0d1aff581c8dda699ccd63f6e8 Mon Sep 17 00:00:00 2001 From: Kassian Sun Date: Thu, 20 Apr 2023 16:53:41 +0800 Subject: [PATCH] [migration] fix wrong pending_stop notification --- plugin/migration/pipeline.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go index d575d0c0..2a56380e 100644 --- a/plugin/migration/pipeline.go +++ b/plugin/migration/pipeline.go @@ -458,8 +458,7 @@ func (p *DispatcherProcessor) handlePendingStopSubTask(taskItem *task2.Task) err // all subtask stopped or error or complete if len(tasks) == 0 { taskItem.Status = task2.StatusStopped - p.sendMajorTaskNotification(taskItem) - p.saveTaskAndWriteLog(taskItem, "", nil, fmt.Sprintf("task [%s] stopped", taskItem.ID)) + p.saveTaskAndWriteLog(taskItem, "", nil, fmt.Sprintf("index migration task [%s] stopped", taskItem.ID)) // clean disk queue if manually stopped p.cleanGatewayQueue(taskItem) }