sink: fix the memory leak in sink manager (#1401)

pingcap · Feb 4, 2021 · a37efea · a37efea
1 parent 79e4595
commit a37efea
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/sink/manager.go b/cdc/sink/manager.go
@@ -146,7 +146,7 @@ func (t *tableSink) FlushRowChangedEvents(ctx context.Context, resolvedTs uint64
 		return t.manager.flushBackendSink(ctx)
 	}
 	resolvedRows := t.buffer[:i]
-	t.buffer = t.buffer[i:]
+	t.buffer = append(make([]*model.RowChangedEvent, 0, len(t.buffer[i:])), t.buffer[i:]...)
 
 	err := t.manager.backendSink.EmitRowChangedEvents(ctx, resolvedRows...)
 	if err != nil {