diff --git a/internal/client/client_test.go b/internal/client/client_test.go index b4babef70e..3436406ecc 100644 --- a/internal/client/client_test.go +++ b/internal/client/client_test.go @@ -931,7 +931,6 @@ func TestRandomRestartStoreAndForwarding(t *testing.T) { conn, err := client1.getConnArray(addr1, true) assert.Nil(t, err) - count := int64(0) for j := 0; j < concurrency; j++ { wg.Add(1) go func() { @@ -946,7 +945,6 @@ func TestRandomRestartStoreAndForwarding(t *testing.T) { forwardedHost = addr2 } _, err := sendBatchRequest(context.Background(), addr1, forwardedHost, conn.batchConn, req, time.Millisecond*50, 0) - atomic.AddInt64(&count, 1) if err == nil || err.Error() == "EOF" || err.Error() == "rpc error: code = Unavailable desc = error reading from server: EOF" ||