processor: cancel all tables all at once (#2089) (#2094)

pingcap · Jul 17, 2021 · d0c5faf · d0c5faf
1 parent ea86b2b
commit d0c5faf
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go
@@ -777,6 +777,8 @@ func (p *processor) doGCSchemaStorage() error {
 func (p *processor) Close() error {
 	for _, tbl := range p.tables {
 		tbl.Cancel()
+	}
+	for _, tbl := range p.tables {
 		tbl.Wait()
 	}
 	p.cancel()