From d1376f6b7c08e01ab8785042af047075b06e37e4 Mon Sep 17 00:00:00 2001
From: suxb201 <sxb201@qq.com>
Date: Mon, 10 Oct 2022 17:08:30 +0800
Subject: [PATCH] bugfix: call Add() for WaitGroup

---
 internal/writer/redis.go | 1 +
 1 file changed, 1 insertion(+)

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
 }