fix context cause.

pingcap · Oct 12, 2023 · 4c8ca30 · 4c8ca30
1 parent 4abfb0a
commit 4c8ca30
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/cdc/sink/dmlsink/mq/mq_dml_sink.go b/cdc/sink/dmlsink/mq/mq_dml_sink.go
@@ -111,10 +111,14 @@ func newDMLSink(
 		s.alive.Unlock()
 		close(s.dead)
 
-		if err != nil && errors.Cause(err) != context.Canceled {
+		if err == nil {
+			return
+		}
+
+		if context.Cause(ctx) != nil {
 			select {
 			case <-ctx.Done():
-			case errCh <- err:
+			case errCh <- ctx.Err():
 			}
 		}
 	}()