浏览代码

set gRPC maxInboundMessageSize to Integer.MAX_VALUE

zhiru 6 年之前
父节点
当前提交
289603931c
共有 1 个文件被更改,包括 2 次插入1 次删除
  1. 2 1
      src/main/java/io/milvus/client/MilvusGrpcClient.java

+ 2 - 1
src/main/java/io/milvus/client/MilvusGrpcClient.java

@@ -33,8 +33,9 @@ public class MilvusGrpcClient implements MilvusClient {
             }
             }
 
 
             channel = ManagedChannelBuilder
             channel = ManagedChannelBuilder
-                    .forAddress(connectParam.getHost(), Integer.parseInt(connectParam.getPort()))
+                    .forAddress(connectParam.getHost(), port)
                     .usePlaintext()
                     .usePlaintext()
+                    .maxInboundMessageSize(Integer.MAX_VALUE)
                     .build();
                     .build();
 
 
             ConnectivityState connectivityState;
             ConnectivityState connectivityState;