From e3449a6fbc1e91f7a6a3c47db03deb56318b8088 Mon Sep 17 00:00:00 2001 From: luowei Date: Fri, 13 Oct 2023 11:38:28 +0800 Subject: [PATCH] set the limitation as a max number to avoid receive limitation --- sqle/driver/common/grpc.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/sqle/driver/common/grpc.go b/sqle/driver/common/grpc.go index 9a34caa3da..55198934d2 100644 --- a/sqle/driver/common/grpc.go +++ b/sqle/driver/common/grpc.go @@ -1,6 +1,8 @@ package common import ( + "math" + "google.golang.org/grpc" ) @@ -8,7 +10,9 @@ import ( var GRPCDialOptions = []grpc.DialOption{} // custom GRPC server options -var GRPCServerOptions = []grpc.ServerOption{} +var GRPCServerOptions = []grpc.ServerOption{ + grpc.MaxRecvMsgSize(math.MaxInt32), +} func NewGRPCServer(opts []grpc.ServerOption) *grpc.Server { return grpc.NewServer(append(opts, GRPCServerOptions...)...)