diff --git a/store/tikv/client_batch.go b/store/tikv/client_batch.go index 6f4fcad407042..cbcc68e6981be 100644 --- a/store/tikv/client_batch.go +++ b/store/tikv/client_batch.go @@ -215,8 +215,8 @@ func (c *batchCommandsClient) send(request *tikvpb.BatchCommandsRequest, entries c.batched.Store(requestID, entries[i]) } if err := c.client.Send(request); err != nil { - logutil.BgLogger().Error( - "batch commands send error", + logutil.BgLogger().Info( + "sending batch commands meets error", zap.String("target", c.target), zap.Error(err), ) @@ -260,7 +260,7 @@ func (c *batchCommandsClient) reCreateStreamingClientOnce(err error) error { return nil } - logutil.BgLogger().Error( + logutil.BgLogger().Info( "batchRecvLoop re-create streaming fail", zap.String("target", c.target), zap.Error(err), @@ -283,8 +283,11 @@ func (c *batchCommandsClient) batchRecvLoop(cfg config.TiKVClient, tikvTransport for { resp, err := c.recv() if err != nil { - logutil.BgLogger().Error( - "batchRecvLoop error when receive", + if c.isStopped() { + return + } + logutil.BgLogger().Info( + "batchRecvLoop fails when receiving, needs to reconnect", zap.String("target", c.target), zap.Error(err), )