From ab7c666e9183202e78c206106aaed20afaea8a94 Mon Sep 17 00:00:00 2001
From: Zixiong Liu <liuzixiong@pingcap.com>
Date: Fri, 18 Jun 2021 12:48:35 +0800
Subject: [PATCH] fix

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

diff --git a/cdc/processor/processor.go b/cdc/processor/processor.go
index 9342c51ad86..9bd167b42cc 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()