demo

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

@@ -69,7 +69,8 @@ public class I2IMilvusDataImport {
         rdd.foreachPartition(lines -> {
             ConnectParam connectParam = ConnectParam.newBuilder()
                     .withUri(finalMilvusUrl)
-                    .withToken(finalMilvusToken)
+                    //.withToken(finalMilvusToken)
+                    .withAuthorization("emr", "Qingqu@2024")
                     //.withConnectTimeout(60L, TimeUnit.SECONDS)
                     .build();
             RetryParam retryParam = RetryParam.newBuilder()