puller: fix potential stuck (#1066)

close #1067
pingcap · Mar 6, 2025 · cbbc4fe · cbbc4fe
1 parent 4771d84
commit cbbc4fe
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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{},