add jobWg.wait

pingcap · Jan 14, 2020 · 20cfd53 · 20cfd53
1 parent 92ede5b
commit 20cfd53
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/syncer/syncer.go b/syncer/syncer.go
@@ -1056,6 +1056,7 @@ func (s *Syncer) Run(ctx context.Context) (err error) {
 			err = terror.ErrSyncerUnitPanic.Generate(err1)
 		}
 
+		s.jobWg.Wait()
 		if err2 := s.flushCheckPoints(); err2 != nil {
 			s.tctx.L().Warn("fail to flush check points when exit task", zap.Error(err2))
 		}