sorter: reduce memory malloc to avoid too much CPU overhead (#1854) (#…

…1863)
pingcap · May 27, 2021 · 669c904 · 669c904
1 parent 5069d1d
commit 669c904
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/cdc/puller/sorter/heap_sorter.go b/cdc/puller/sorter/heap_sorter.go
@@ -33,6 +33,7 @@ import (
 
 const (
  flushRateLimitPerSecond = 10
+ sortHeapCapacity = 32
 )
 
 type flushTask struct {
@@ -86,7 +87,7 @@ func newHeapSorter(id int, out chan *flushTask) *heapSorter {
  id: id,
  inputCh: make(chan *model.PolymorphicEvent, 1024*1024),
  outputCh: out,
- heap: make(sortHeap, 0, 65536),
+ heap: make(sortHeap, 0, sortHeapCapacity),
  canceller: new(asyncCanceller),
  }
 }
@@ -159,7 +160,7 @@ func (h *heapSorter) flush(ctx context.Context, maxResolvedTs uint64) error {
  return nil
  }
  oldHeap = h.heap
- h.heap = make(sortHeap, 0, 65536)
+ h.heap = make(sortHeap, 0, sortHeapCapacity)
  } else {
  task.dealloc = func() error {
  task.markDeallocated()