From ddea3965add9dbf27a9fba4ebee4ce4ce2d5c7b6 Mon Sep 17 00:00:00 2001 From: lance6716 Date: Wed, 3 Feb 2021 15:19:36 +0800 Subject: [PATCH] streamer: fix unstable Ci introduced in #1364 (#1421) --- pkg/streamer/reader.go | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/pkg/streamer/reader.go b/pkg/streamer/reader.go index 8087b23899..2d27d4659f 100644 --- 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)