Skip to content

Commit 3e12cd7

Browse files
authored
lightning: unlimited grpc MaxCallRecvMsgSize for TikvImporter (#56771) (#59569)
close #56114
1 parent cdffa79 commit 3e12cd7

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

br/pkg/lightning/backend/local/local.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,9 @@ const (
8989
// maxWriteAndIngestRetryTimes is the max retry times for write and ingest.
9090
// A large retry times is for tolerating tikv cluster failures.
9191
maxWriteAndIngestRetryTimes = 30
92-
maxRetryBackoffTime = 30 * time.Second
92+
// Unlimited RPC receive message size for TiKV importer
93+
unlimitedRPCRecvMsgSize = math.MaxInt32
94+
maxRetryBackoffTime = 30 * time.Second
9395

9496
gRPCKeepAliveTime = 10 * time.Minute
9597
gRPCKeepAliveTimeout = 5 * time.Minute
@@ -168,6 +170,7 @@ func (f *importClientFactoryImpl) makeConn(ctx context.Context, storeID uint64)
168170
ctx,
169171
addr,
170172
opt,
173+
grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(unlimitedRPCRecvMsgSize)),
171174
grpc.WithConnectParams(grpc.ConnectParams{Backoff: bfConf}),
172175
grpc.WithKeepaliveParams(keepalive.ClientParameters{
173176
Time: gRPCKeepAliveTime,

0 commit comments

Comments
 (0)