diff --git a/examples/src/main/java/io/milvus/v1/BulkWriterExample.java b/examples/src/main/java/io/milvus/v1/BulkWriterExample.java index 5b618cea1..cea07c4c4 100644 --- a/examples/src/main/java/io/milvus/v1/BulkWriterExample.java +++ b/examples/src/main/java/io/milvus/v1/BulkWriterExample.java @@ -499,6 +499,7 @@ private void callBulkInsert(CollectionSchemaParam collectionSchema, List> batchFiles) throws Interru MilvusImportRequest milvusImportRequest = MilvusImportRequest.builder() .collectionName(ALL_TYPES_COLLECTION_NAME) .files(batchFiles) + .apiKey(USER_NAME + ":" + PASSWORD) .options(options) .build(); String bulkImportResult = BulkImportUtils.bulkImport(url, milvusImportRequest); @@ -452,7 +453,9 @@ private static void callBulkInsert(List> batchFiles) throws Interru System.out.println("Create a bulkInert task, job id: " + jobId); System.out.println("\n===================== listBulkInsertJobs() ===================="); - MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME).build(); + MilvusListImportJobsRequest listImportJobsRequest = MilvusListImportJobsRequest.builder().collectionName(ALL_TYPES_COLLECTION_NAME) + .apiKey(USER_NAME + ":" + PASSWORD) + .build(); String listImportJobsResult = BulkImportUtils.listImportJobs(url, listImportJobsRequest); System.out.println(listImportJobsResult); while (true) { @@ -462,6 +465,7 @@ private static void callBulkInsert(List> batchFiles) throws Interru System.out.println("\n===================== getBulkInsertState() ===================="); MilvusDescribeImportRequest request = MilvusDescribeImportRequest.builder() .jobId(jobId) + .apiKey(USER_NAME + ":" + PASSWORD) .build(); String getImportProgressResult = BulkImportUtils.getImportProgress(url, request); System.out.println(getImportProgressResult); diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java index ceb730cee..9fae25d6c 100644 --- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java +++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/describe/BaseDescribeImportRequest.java @@ -33,7 +33,8 @@ public class BaseDescribeImportRequest implements Serializable { private static final long serialVersionUID = -787626534606813089L; /** - * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it. + * If you are calling the cloud API, this parameter should be set to your API_KEY. + * If you are using Milvus directly, this parameter should be set to your userName:password. */ private String apiKey; } diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java index 481cc08dc..99fd7e194 100644 --- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java +++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/import_/BaseImportRequest.java @@ -34,7 +34,8 @@ public class BaseImportRequest implements Serializable { private static final long serialVersionUID = 8192049841043084620L; /** - * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it. + * If you are calling the cloud API, this parameter should be set to your API_KEY. + * If you are using Milvus directly, this parameter should be set to your userName:password. */ private String apiKey; diff --git a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java index a6f4a4bd4..d2e8101e2 100644 --- a/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java +++ b/sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/request/list/BaseListImportJobsRequest.java @@ -34,7 +34,8 @@ public class BaseListImportJobsRequest implements Serializable { private static final long serialVersionUID = -1890380396466908530L; /** - * If you are calling the cloud API, this parameter needs to be filled in; otherwise, you can ignore it. + * If you are calling the cloud API, this parameter should be set to your API_KEY. + * If you are using Milvus directly, this parameter should be set to your userName:password. */ private String apiKey; }