test(dm): fix datarace for testSyncerSuite.TestRun (pingcap#4305)

close pingcap#4280
zhaoxinyu · Jan 20, 2022 · 3e00852 · 3e00852
1 parent a4c4402
commit 3e00852
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/dm/syncer/syncer_test.go b/dm/syncer/syncer_test.go
@@ -957,6 +957,7 @@ func (s *testSyncerSuite) TestRun(c *C) {
 	}
 
 	cancel()
+	<-resultCh // wait for the process to finish
 	// when syncer exit Run(), will flush job
 	syncer.Pause()
 
@@ -1023,6 +1024,7 @@ func (s *testSyncerSuite) TestRun(c *C) {
 	testJobs.RUnlock()
 
 	cancel()
+	<-resultCh // wait for the process to finish
 	syncer.Close()
 	c.Assert(syncer.isClosed(), IsTrue)