diff --git a/plugin/migration/pipeline.go b/plugin/migration/pipeline.go
index 2b12b8b9..36ebc4bc 100644
--- a/plugin/migration/pipeline.go
+++ b/plugin/migration/pipeline.go
@@ -274,6 +274,13 @@ func (p *DispatcherProcessor) handlePendingStopMajorTask(taskItem *task2.Task) e
 		"query": util.MapStr{
 			"bool": util.MapStr{
 				"must": []util.MapStr{
+					{
+						"term": util.MapStr{
+							"parent_id": util.MapStr{
+								"value": taskItem.ID,
+							},
+						},
+					},
 					{
 						"term": util.MapStr{
 							"metadata.labels.business_id": "index_migration",