fix log message (milvus-io#1488) (milvus-io#1502)

Signed-off-by: 唐家明 <tangjiaming@kuaishou.com>
Co-authored-by: Cplus-plus <57971497+Cplus-plus@users.noreply.github.com>
Co-authored-by: 唐家明 <tangjiaming@kuaishou.com>

Author: 3 people

sdk-core/src/main/java/io/milvus/client/MilvusClient.java

@@ -45,10 +45,16 @@
 
 import java.util.concurrent.TimeUnit;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
 /**
  * The Milvus Client Interface
  */
 public interface MilvusClient {
+
+    Logger logger = LoggerFactory.getLogger(MilvusClient.class);
+
     /**
      * Timeout setting for rpc call.
      *
@@ -99,7 +105,7 @@ default void close() {
         try {
             close(TimeUnit.MINUTES.toSeconds(1));
         } catch (InterruptedException e) {
-            System.out.println("Interrupted during shutdown Milvus client!");
+            logger.error("Interrupted during shutdown Milvus client!");
         }
     }
 

sdk-core/src/main/java/io/milvus/orm/iterator/SearchIterator.java

@@ -227,7 +227,6 @@ private void setUpRangeParameters(List<QueryResultsWrapper.RowRecord> page) {
         tailBand = getDistance(lastHit);
         String msg = String.format("set up init parameter for searchIterator width:%s tail_band:%s", width, tailBand);
         logger.debug(msg);
-//        System.out.println(msg);
     }
 
     private void updateFilteredIds(SearchResultsWrapper searchResultsWrapper) {

sdk-core/src/main/java/io/milvus/v2/client/MilvusClientV2.java

@@ -1044,7 +1044,7 @@ public void close() {
         try {
             close(TimeUnit.MINUTES.toSeconds(1));
         } catch (InterruptedException e) {
-            System.out.println("Interrupted during shutdown Milvus client!");
+            logger.error("Interrupted during shutdown Milvus client!");
         }
     }
 

sdk-core/src/main/java/io/milvus/v2/service/collection/CollectionService.java

@@ -481,7 +481,7 @@ private void WaitForLoadCollection(MilvusServiceGrpc.MilvusServiceBlockingStub b
                 Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
-                System.out.println("Thread was interrupted, Failed to complete operation");
+                logger.error("Thread was interrupted, Failed to complete operation");
                 return; // or handle interruption appropriately
             }
         }

sdk-core/src/main/java/io/milvus/v2/service/index/IndexService.java

@@ -249,7 +249,7 @@ private void WaitForIndexComplete(MilvusServiceGrpc.MilvusServiceBlockingStub bl
                 Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
-                System.out.println("Thread was interrupted, failed to complete operation");
+                logger.error("Thread was interrupted, failed to complete operation");
                 return; // or handle interruption appropriately
             }
         }

sdk-core/src/main/java/io/milvus/v2/service/partition/PartitionService.java

@@ -152,7 +152,7 @@ private void WaitForLoadPartitions(MilvusServiceGrpc.MilvusServiceBlockingStub b
                 Thread.sleep(500); // Sleep for 0.5 second. Adjust this value as needed.
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
-                System.out.println("Thread was interrupted, failed to complete operation");
+                logger.error("Thread was interrupted, failed to complete operation");
                 return; // or handle interruption appropriately
             }
         }

sdk-core/src/main/java/io/milvus/v2/service/vector/VectorService.java

@@ -372,7 +372,7 @@ public RunAnalyzerResp runAnalyzer(MilvusServiceGrpc.MilvusServiceBlockingStub b
         builder.addAllAnalyzerNames(analyzerNames);
 
         String params = JsonUtils.toJson(request.getAnalyzerParams());
-        System.out.println(params);
+        logger.debug(params);
         RunAnalyzerRequest runRequest = builder.addAllPlaceholder(byteStrings)
                 .setAnalyzerParams(params)
                 .setWithDetail(request.getWithDetail())