demo

recommend-model-produce/pom.xml

@@ -208,6 +208,10 @@
                     <artifactId>guava</artifactId>
                     <groupId>com.google.guava</groupId>
                 </exclusion>
+                <exclusion>
+                    <artifactId>grpc-core</artifactId>
+                    <groupId>io.grpc</groupId>
+                </exclusion>
             </exclusions>
         </dependency>
         <dependency>
@@ -243,7 +247,7 @@
         </dependency>
         <dependency>
             <groupId>io.grpc</groupId>
-            <artifactId>grpc-api</artifactId>
+            <artifactId>grpc-core</artifactId>
             <version>1.59.1</version>
             <exclusions>
                 <exclusion>

recommend-model-produce/src/main/java/com/tzld/piaoquan/recommend/model/produce/i2i/I2IMilvusDataImport.java

@@ -63,17 +63,6 @@ public class I2IMilvusDataImport {
         JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext());
         JavaRDD<String> rdd = jsc.textFile(file);
 
-        try {
-            Socket socket = new Socket();
-            socket.connect(new InetSocketAddress("in01-bf9dcd371016170.ali-cn-hangzhou.vectordb.zilliz.com.cn", 19530),
-                    5000);
-            System.out.println("is reachable.");
-        } catch (UnknownHostException e) {
-            log.error(" could not be resolved: " + e.getMessage(), e);
-        } catch (Exception e) {
-            System.err.println("An error occurred: " + e.getMessage());
-        }
-
         // 定义处理数据的函数
         String finalMilvusUrl = milvusUrl;
         String finalMilvusToken = milvusToken;