Browse Source

fix keepAliveTimeout timeunit error (#367)

Signed-off-by: pengshaocheng <psc0606@163.com>

Signed-off-by: pengshaocheng <psc0606@163.com>
Joe.P 2 năm trước cách đây
mục cha
commit
8b8476163d

+ 1 - 1
src/main/java/io/milvus/param/ConnectParam.java

@@ -163,7 +163,7 @@ public class ConnectParam {
          * @return <code>Builder</code>
          */
         public Builder withKeepAliveTimeout(long keepAliveTimeout, @NonNull TimeUnit timeUnit) {
-            this.keepAliveTimeoutMs = timeUnit.toNanos(keepAliveTimeout);
+            this.keepAliveTimeoutMs = timeUnit.toMillis(keepAliveTimeout);
             return this;
         }
 

+ 5 - 5
src/test/java/io/milvus/client/MilvusServiceClientTest.java

@@ -170,7 +170,7 @@ class MilvusServiceClientTest {
                 .withPort(port)
                 .withConnectTimeout(connectTimeoutMs, TimeUnit.MILLISECONDS)
                 .withKeepAliveTime(keepAliveTimeMs, TimeUnit.MILLISECONDS)
-                .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.NANOSECONDS)
+                .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.MILLISECONDS)
                 .keepAliveWithoutCalls(true)
                 .withIdleTimeout(idleTimeoutMs, TimeUnit.MILLISECONDS)
                 .build();
@@ -190,7 +190,7 @@ class MilvusServiceClientTest {
                         .withPort(0xFFFF + 1)
                         .withConnectTimeout(connectTimeoutMs, TimeUnit.MILLISECONDS)
                         .withKeepAliveTime(keepAliveTimeMs, TimeUnit.MILLISECONDS)
-                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.NANOSECONDS)
+                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.MILLISECONDS)
                         .keepAliveWithoutCalls(true)
                         .withIdleTimeout(idleTimeoutMs, TimeUnit.MILLISECONDS)
                         .build()
@@ -202,7 +202,7 @@ class MilvusServiceClientTest {
                         .withPort(port)
                         .withConnectTimeout(-1, TimeUnit.MILLISECONDS)
                         .withKeepAliveTime(keepAliveTimeMs, TimeUnit.MILLISECONDS)
-                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.NANOSECONDS)
+                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.MILLISECONDS)
                         .keepAliveWithoutCalls(true)
                         .withIdleTimeout(idleTimeoutMs, TimeUnit.MILLISECONDS)
                         .build()
@@ -214,7 +214,7 @@ class MilvusServiceClientTest {
                         .withPort(port)
                         .withConnectTimeout(connectTimeoutMs, TimeUnit.MILLISECONDS)
                         .withKeepAliveTime(-1, TimeUnit.MILLISECONDS)
-                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.NANOSECONDS)
+                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.MILLISECONDS)
                         .keepAliveWithoutCalls(true)
                         .withIdleTimeout(idleTimeoutMs, TimeUnit.MILLISECONDS)
                         .build()
@@ -238,7 +238,7 @@ class MilvusServiceClientTest {
                         .withPort(port)
                         .withConnectTimeout(connectTimeoutMs, TimeUnit.MILLISECONDS)
                         .withKeepAliveTime(keepAliveTimeMs, TimeUnit.MILLISECONDS)
-                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.NANOSECONDS)
+                        .withKeepAliveTimeout(keepAliveTimeoutMs, TimeUnit.MILLISECONDS)
                         .keepAliveWithoutCalls(true)
                         .withIdleTimeout(-1, TimeUnit.MILLISECONDS)
                         .build()