groot
groot
I didn't see "fs.file.impl.disable.cache" in hadoop doc, it could be a flag to avoid multiple threads sharing the same cached object. If so, it indicates the LocalBulkWriter.flush() is called at...
I think it is ok to set "fs.file.impl.disable.cache = true" in the Buffer.java. Do you think there is any risk?
We don't intend to release new versions for v2.4.x, except for critical defects. I will add the line in the next minor version of v2.5.x. Do you think it makes...
A new version v2.5.9 has already been released with this fix.
MilvusServiceClient.flush() 这个接口调太多了,milvus server不允许密集调用flush() flush()接口一般不需要手动调用,milvus内部自己会flush。一般只有在一些测试性能测试功能的场景才会手动调用flush(),在所有数据都插入完成后调用一次flush()即可。
github.com/zilliztech下面有一个spark-milvus的项目里使用的是spark 3.3.2和milvus sdk 2.5.4,这两个版本应该可以兼容: https://github.com/zilliztech/spark-milvus/blob/main/pom.xml 你的报错里面com.google.common.base.Preconditions.checkArgument()这个来自于guava,可能是guava的版本冲突
Which api returns ASCII characters for chinese?
I didn't find this error message in milvus source code and java sdk source code. Which version of your milvus and sdk? The message says some partitions of the collection...
Use the '`SearchResultsWrapper`' class to print out all the search results: ``` SearchParam searchParam = SearchParam.newBuilder() .withCollectionName(randomCollectionName) .withMetricType(MetricType.IP) .withTopK(topK) .withVectors(targetVectors) .withVectorFieldName(field2Name) .addOutField(field4Name) .build(); R searchR = client.search(searchParam); Assertions.assertEquals(R.Status.Success.getCode(), searchR.getStatus().intValue()); SearchResultsWrapper...
It is a bug of SearchResultsWrapper.getRowRecords(), which is fixed by #757 and #758. In fact, getRowRecords() is a wrapper of getIDScore(), it is better to use getIDScore() to get the...