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

… a processor (#11279) (#11438) close #11278
pingcap · Jul 31, 2024 · 94f1168 · 94f1168
1 parent 126e30b
commit 94f1168
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:
+		}
 	}
 }