cdc: recycle memory for unbounded channel (#9223)

ref #9222
pingcap · Jun 14, 2023 · 2473041 · 2473041
1 parent 8503b05
commit 2473041
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/pkg/chann/chann.go b/pkg/chann/chann.go
@@ -177,7 +177,6 @@ func (ch *Chann[T]) Close() {
 func (ch *Chann[T]) unboundedProcessing() {
 	var nilT T
 
-	ch.q = make([]T, 0, 1<<10)
 	for {
 		select {
 		case e, ok := <-ch.in:
@@ -208,9 +207,6 @@ func (ch *Chann[T]) unboundedProcessing() {
 				return
 			}
 		}
-		if cap(ch.q) < 1<<5 {
-			ch.q = make([]T, 0, 1<<10)
-		}
 	}
 }