From cbbc4fe1bc9cc04ae902efd19ff3f58491cb9fda Mon Sep 17 00:00:00 2001
From: lidezhu <47731263+lidezhu@users.noreply.github.com>
Date: Thu, 6 Mar 2025 15:11:26 +0800
Subject: [PATCH] puller: fix potential stuck (#1066)

close pingcap/ticdc#1067
---
 logservice/logpuller/region_request_worker.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/logservice/logpuller/region_request_worker.go b/logservice/logpuller/region_request_worker.go
index 19e3218f9..8584317a9 100644
--- a/logservice/logpuller/region_request_worker.go
+++ b/logservice/logpuller/region_request_worker.go
@@ -365,6 +365,7 @@ func (s *regionRequestWorker) processRegionSendTask(
 		// It means it's a special task for stopping the table.
 		if region.isStopped() {
 			req := &cdcpb.ChangeDataRequest{
+				Header:    &cdcpb.Header{ClusterId: s.client.clusterID, TicdcVersion: version.ReleaseSemver()},
 				RequestId: uint64(subID),
 				Request: &cdcpb.ChangeDataRequest_Deregister_{
 					Deregister: &cdcpb.ChangeDataRequest_Deregister{},