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

pingcap · Jul 18, 2021 · 2e118a6 · 2e118a6
1 parent a534d31
commit 2e118a6
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()