Skip to content

Commit 6973b6b

Browse files
authored
puller: fix potential stuck (#12080)
close #12081
1 parent 4d70424 commit 6973b6b

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

cdc/kv/shared_stream.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -318,6 +318,7 @@ func (s *requestedStream) send(ctx context.Context, c *SharedClient, rs *request
318318
if region.isStopped() {
319319
if s.multiplexing != nil {
320320
req := &cdcpb.ChangeDataRequest{
321+
Header: &cdcpb.Header{ClusterId: c.clusterID, TicdcVersion: version.ReleaseSemver()},
321322
RequestId: uint64(subscriptionID),
322323
Request: &cdcpb.ChangeDataRequest_Deregister_{
323324
Deregister: &cdcpb.ChangeDataRequest_Deregister{},

0 commit comments

Comments
 (0)