From 2e118a6ac06ea543a258bdf7a943e09ff7ae78ae Mon Sep 17 00:00:00 2001
From: Ti Chi Robot <ti-community-prow-bot@tidb.io>
Date: Sun, 18 Jul 2021 20:41:33 +0800
Subject: [PATCH] processor: cancel all tables all at once (#2089) (#2095)

---
 cdc/processor/processor.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go
index aa0797a8a1b..5dd89d3bdf9 100644
--- 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()