diff --git a/internal/writer/redis.go b/internal/writer/redis.go
index 0223109..996f835 100644
--- a/internal/writer/redis.go
+++ b/internal/writer/redis.go
@@ -31,6 +31,7 @@ func NewRedisWriter(address string, username string, password string, isTls bool
 	log.Infof("redisWriter connected to redis successful. address=[%s]", address)
 	rw.cmdBuffer = new(bytes.Buffer)
 	rw.chWaitReply = make(chan *entry.Entry, config.Config.Advanced.PipelineCountLimit)
+	rw.chWg.Add(1)
 	go rw.flushInterval()
 	return rw
 }