streamer: fix unstable Ci introduced in pingcap#1364 (pingcap#1421)

ti-srebot · Feb 3, 2021 · ddea396 · ddea396
1 parent c82ba8c
commit ddea396
Showing 1 changed file with 2 additions and 10 deletions.
diff --git a/pkg/streamer/reader.go b/pkg/streamer/reader.go
@@ -569,21 +569,13 @@ func (r *BinlogReader) parseFile(
 
 	wg.Add(1)
 	go func(latestPos int64) {
-		defer func() {
-			close(switchCh)
-			close(switchErrCh)
-			wg.Done()
-		}()
+		defer wg.Done()
 		needSwitchSubDir(newCtx, r.cfg.RelayDir, currentUUID, fullPath, latestPos, switchCh, switchErrCh)
 	}(latestPos)
 
 	wg.Add(1)
 	go func(latestPos int64) {
-		defer func() {
-			close(updatePathCh)
-			close(updateErrCh)
-			wg.Done()
-		}()
+		defer wg.Done()
 		relaySubDirUpdated(newCtx, watcherInterval, relayLogDir, fullPath, relayLogFile, latestPos, updatePathCh, updateErrCh)
 	}(latestPos)