sink(ticdc): Fix a slice overwriting problem (#7759)

ref #6797
pingcap · Dec 1, 2022 · 9ef9702 · 9ef9702
1 parent e7e2894
commit 9ef9702
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cdc/sinkv2/eventsink/cloudstorage/dml_worker.go b/cdc/sinkv2/eventsink/cloudstorage/dml_worker.go
@@ -132,7 +132,8 @@ func (d *dmlWorker) backgroundFlushMsgs(ctx context.Context) {
 						version:   tableInfo.Version,
 					}
 					d.tableEvents.mu.Lock()
-					events := d.tableEvents.fragments[table]
+					events := make([]eventFragment, len(d.tableEvents.fragments[table]))
+					copy(events, d.tableEvents.fragments[table])
 					d.tableEvents.fragments[table] = d.tableEvents.fragments[table][:0]
 					d.tableEvents.mu.Unlock()
 					if len(events) == 0 {