fix

pingcap · Jun 18, 2021 · ab7c666 · ab7c666
1 parent 9aa4047
commit ab7c666
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()