sorter(cdc): fix a bug that Pebble sorter can be stucked when closing…

… a processor (#11279) close #11278
pingcap · Jun 11, 2024 · e3b0bc7 · e3b0bc7
1 parent cded157
commit e3b0bc7
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/cdc/processor/sourcemanager/sorter/pebble/event_sorter.go b/cdc/processor/sourcemanager/sorter/pebble/event_sorter.go
@@ -495,7 +495,11 @@ func (s *EventSorter) handleEvents(
 		if !ok {
 			return
 		}
-		batchCh <- batchEvent
+		select {
+		case <-s.closed:
+			return
+		case batchCh <- batchEvent:
+		}
 	}
 }