Skip to content

Commit 1f41fe1

Browse files
uncle-cyhcshcyh
authored andcommitted
fix:remove collection schema cache after dropCollection (#1550)
Signed-off-by: uncle <772817297@qq.com> Co-authored-by: uncle <772817297@qq.com>
1 parent a3f7d2f commit 1f41fe1

2 files changed

Lines changed: 2 additions & 1 deletion

File tree

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

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -320,6 +320,7 @@ public ListCollectionsResp listCollections() {
320320
*/
321321
public void dropCollection(DropCollectionReq request) {
322322
rpcUtils.retry(()-> collectionService.dropCollection(this.getRpcStub(), request));
323+
vectorService.removeCollectionCache(request.getDatabaseName(), request.getCollectionName());
323324
}
324325
/**
325326
* Alter a collection in Milvus.

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ private void cleanCacheIfFailed(Status status, String databaseName, String colle
9999
}
100100
}
101101

102-
private void removeCollectionCache(String databaseName, String collectionName) {
102+
public void removeCollectionCache(String databaseName, String collectionName) {
103103
String key = GTsDict.CombineCollectionName(actualDbName(databaseName), collectionName);
104104
cacheCollectionInfo.remove(key);
105105
}

0 commit comments

Comments
 (0)