tikvclient: adjust log level in store/tikv/client_batch.go (pingcap#1…

…2302) Signed-off-by: qupeng <qupeng@pingcap.com>
hicqu · Sep 25, 2019 · b9390a9 · b9390a9
1 parent 3716ac5
commit b9390a9
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/store/tikv/client_batch.go b/store/tikv/client_batch.go
@@ -207,8 +207,8 @@ func (c *batchCommandsClient) send(request *tikvpb.BatchCommandsRequest, entries
 		c.batched.Store(requestID, entries[i])
 	}
 	if err := c.client.Send(request); err != nil {
-		logutil.Logger(context.Background()).Error(
-			"batch commands send error",
+		logutil.Logger(context.Background()).Info(
+			"sending batch commands meets error",
 			zap.String("target", c.target),
 			zap.Error(err),
 		)
@@ -252,7 +252,7 @@ func (c *batchCommandsClient) reCreateStreamingClientOnce(err error) error {
 
 		return nil
 	}
-	logutil.Logger(context.Background()).Error(
+	logutil.Logger(context.Background()).Info(
 		"batchRecvLoop re-create streaming fail",
 		zap.String("target", c.target),
 		zap.Error(err),
@@ -275,8 +275,11 @@ func (c *batchCommandsClient) batchRecvLoop(cfg config.TiKVClient, tikvTransport
 	for {
 		resp, err := c.recv()
 		if err != nil {
-			logutil.Logger(context.Background()).Error(
-				"batchRecvLoop error when receive",
+			if c.isStopped() {
+				return
+			}
+			logutil.Logger(context.Background()).Info(
+				"batchRecvLoop fails when receiving, needs to reconnect",
 				zap.String("target", c.target),
 				zap.Error(err),
 			)