Browse Source

Fix a pre-connect timeout issue (#1105)

Signed-off-by: yhmo <yihua.mo@zilliz.com>
groot 8 months ago
parent
commit
5aad7eaeab
1 changed files with 1 additions and 1 deletions
  1. 1 1
      src/main/java/io/milvus/v2/client/MilvusClientV2.java

+ 1 - 1
src/main/java/io/milvus/v2/client/MilvusClientV2.java

@@ -143,7 +143,7 @@ public class MilvusClientV2 {
                 .setLocalTime(clientUtils.getLocalTimeStr())
                 .build();
         ConnectRequest req = ConnectRequest.newBuilder().setClientInfo(info).build();
-        ConnectResponse resp = blockingStub.withDeadlineAfter(1, TimeUnit.SECONDS)
+        ConnectResponse resp = blockingStub.withDeadlineAfter(connectConfig.getConnectTimeoutMs(), TimeUnit.MILLISECONDS)
                 .connect(req);
         if (resp.getStatus().getCode() != 0 || !resp.getStatus().getErrorCode().equals(io.milvus.grpc.ErrorCode.Success)) {
             throw new RuntimeException("Failed to initialize connection. Error: " + resp.getStatus().getReason());