diff --git a/plugin/migration/cluster_comparison/cluster_comparison.go b/plugin/migration/cluster_comparison/cluster_comparison.go
index bfeb1669..2bdf3b43 100644
--- a/plugin/migration/cluster_comparison/cluster_comparison.go
+++ b/plugin/migration/cluster_comparison/cluster_comparison.go
@@ -412,6 +412,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
 }
 
 func (p *processor) sendMajorTaskNotification(taskItem *task.Task) {
+	// don't send notification for repeating child tasks
+	if len(taskItem.ParentId) > 0 {
+		return
+	}
+
 	config := migration_model.ClusterComparisonTaskConfig{}
 	err := migration_util.GetTaskConfig(taskItem, &config)
 	if err != nil {
diff --git a/plugin/migration/cluster_migration/cluster_migration.go b/plugin/migration/cluster_migration/cluster_migration.go
index 3dec3b8f..80b136c7 100644
--- a/plugin/migration/cluster_migration/cluster_migration.go
+++ b/plugin/migration/cluster_migration/cluster_migration.go
@@ -439,6 +439,11 @@ func (p *processor) saveTaskAndWriteLog(taskItem *task.Task, taskResult *task.Ta
 }
 
 func (p *processor) sendMajorTaskNotification(taskItem *task.Task) {
+	// don't send notification for repeating child tasks
+	if len(taskItem.ParentId) > 0 {
+		return
+	}
+
 	config := migration_model.ClusterMigrationTaskConfig{}
 	err := migration_util.GetTaskConfig(taskItem, &config)
 	if err != nil {