Skip to content

Commit 07e3783

Browse files
fishiuti-chi-bot
authored andcommitted
lightning: unlimited grpc MaxCallRecvMsgSize for TikvImporter (pingcap#56771)
close pingcap#56114
1 parent cc69648 commit 07e3783

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -113,6 +113,9 @@ var (
113113
// MaxWriteAndIngestRetryTimes is the max retry times for write and ingest.
114114
// A large retry times is for tolerating tikv cluster failures.
115115
MaxWriteAndIngestRetryTimes = 30
116+
117+
// Unlimited RPC receive message size for TiKV importer
118+
unlimitedRPCRecvMsgSize = math.MaxInt32
116119
)
117120

118121
// ImportClientFactory is factory to create new import client for specific store.
@@ -166,6 +169,7 @@ func (f *importClientFactoryImpl) makeConn(ctx context.Context, storeID uint64)
166169
addr = store.GetAddress()
167170
}
168171
opts = append(opts,
172+
grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(unlimitedRPCRecvMsgSize)),
169173
grpc.WithConnectParams(grpc.ConnectParams{Backoff: bfConf}),
170174
grpc.WithKeepaliveParams(keepalive.ClientParameters{
171175
Time: gRPCKeepAliveTime,

0 commit comments

Comments
 (0)