This is an automated cherry-pick of pingcap#9894

Signed-off-by: ti-chi-bot <[email protected]>
ti-chi-bot · Dec 26, 2024 · feea7f6 · feea7f6
1 parent 46a22f7
commit feea7f6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cdc/sinkv2/eventsink/mq/mq_dml_sink.go b/cdc/sinkv2/eventsink/mq/mq_dml_sink.go
@@ -123,10 +123,14 @@ func newSink(ctx context.Context,
 
 		if err != nil {
 			if errors.Cause(err) == context.Canceled {
+<<<<<<< HEAD:cdc/sinkv2/eventsink/mq/mq_dml_sink.go
 				if s.cancelErr == nil {
 					return
 				}
 				err = s.cancelErr
+=======
+				err = context.Cause(ctx)
+>>>>>>> 0f4a8a1fcb (kafka(ticdc): fix kafka dml sink report error to sink manager (#9879) (#9894)):cdc/sink/dmlsink/mq/mq_dml_sink.go
 			}
 			select {
 			case errCh <- err: