Skip to content

Commit

Permalink
lightning: unlimited grpc MaxCallRecvMsgSize for TikvImporter (pingca…
Browse files Browse the repository at this point in the history
  • Loading branch information
fishiu authored and ti-chi-bot committed Dec 3, 2024
1 parent bf0766b commit 729f136
Showing 1 changed file with 4 additions and 0 deletions.
4 changes: 4 additions & 0 deletions br/pkg/lightning/backend/local/local.go
Original file line number Diff line number Diff line change
Expand Up @@ -118,6 +118,9 @@ var (
// MaxWriteAndIngestRetryTimes is the max retry times for write and ingest.
// A large retry times is for tolerating tikv cluster failures.
MaxWriteAndIngestRetryTimes = 30

// Unlimited RPC receive message size for TiKV importer
unlimitedRPCRecvMsgSize = math.MaxInt32
)

// ImportClientFactory is factory to create new import client for specific store.
Expand Down Expand Up @@ -171,6 +174,7 @@ func (f *importClientFactoryImpl) makeConn(ctx context.Context, storeID uint64)
addr = store.GetAddress()
}
opts = append(opts,
grpc.WithDefaultCallOptions(grpc.MaxCallRecvMsgSize(unlimitedRPCRecvMsgSize)),
grpc.WithConnectParams(grpc.ConnectParams{Backoff: bfConf}),
grpc.WithKeepaliveParams(keepalive.ClientParameters{
Time: gRPCKeepAliveTime,
Expand Down

0 comments on commit 729f136

Please sign in to comment.