fix

pingcap · Jun 18, 2021 · 27ea4ec · 27ea4ec
1 parent 2a59b8a
commit 27ea4ec
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()