diff --git a/internal/querycoordv2/checkers/channel_checker.go b/internal/querycoordv2/checkers/channel_checker.go
index f84673c23c..ef4ec783f7 100644
--- a/internal/querycoordv2/checkers/channel_checker.go
+++ b/internal/querycoordv2/checkers/channel_checker.go
@@ -71,7 +71,9 @@ func (c *ChannelChecker) Check(ctx context.Context) []task.Task {
 
 	channels := c.dist.ChannelDistManager.GetAll()
 	released := utils.FilterReleased(channels, collectionIDs)
-	tasks = append(tasks, c.createChannelReduceTasks(ctx, released, -1)...)
+	releaseTasks := c.createChannelReduceTasks(ctx, released, -1)
+	task.SetReason("collection released", releaseTasks...)
+	tasks = append(tasks, releaseTasks...)
 	return tasks
 }
 
diff --git a/internal/querycoordv2/task/task.go b/internal/querycoordv2/task/task.go
index 128f549a99..8585206439 100644
--- a/internal/querycoordv2/task/task.go
+++ b/internal/querycoordv2/task/task.go
@@ -249,9 +249,10 @@ func (task *baseTask) String() string {
 		}
 	}
 	return fmt.Sprintf(
-		"[id=%d] [type=%s] [reason=%s] [collectionID=%d] [replicaID=%d] [priority=%s] [actionsCount=%d] [actions=%s]",
+		"[id=%d] [type=%s] [source=%d] [reason=%s] [collectionID=%d] [replicaID=%d] [priority=%s] [actionsCount=%d] [actions=%s]",
 		task.id,
 		GetTaskType(task).String(),
+		task.sourceID,
 		task.reason,
 		task.collectionID,
 		task.replicaID,