[Bug]: Use the Go client to delete the data. After a while, use attu's query interface to query the data. Only part of it was deleted. about milvus HOT 14 OPEN

When the total amount of data to be deleted is more than 40, this problem will not occur. When the total amount of data is more than 200, this problem will occur.

from milvus.

/assign @ThreadDao
please help to reporduce the issue

/unassign

from milvus.

from milvus.

you can try to set the consistency_level param to Strong in the delete method

from milvus.

you can try to set the consistency_level param to Strong in the delete method

how to call delete method by this param? I did not find api doc

from milvus.

I saw a time traval value mentioned in your document. How long will it take before it will be retrieved by default?

from milvus.

@dushulin maybe the go sdk have not give the param, you can set the collection consistency_level to strong, and try to delete the data.

from milvus.

@dushulin maybe the go sdk have not give the param, you can set the collection consistency_level to strong, and try to delete the data.
We need complex expr, so we can only set bounded，can we set consistency_level in query or search function? If not, can you team add this in go sdk?

from milvus.

@congqixia please give this issue a look

from milvus.

@dushulin you can set the consistency_level in search and query request
https://github.com/milvus-io/milvus-sdk-go/blob/e697167f1828049c4c6237f0e3646b77b725ebdf/client/options.go#L174-L179

from milvus.

@dushulin you can set the consistency_level in search and query request https://github.com/milvus-io/milvus-sdk-go/blob/e697167f1828049c4c6237f0e3646b77b725ebdf/client/options.go#L174-L179

Are there fields for curl?

from milvus.

here is the client api

func (c *GrpcClient) Search(ctx context.Context, collName string, partitions []string,
    expr string, outputFields []string, vectors []entity.Vector, vectorField string, metricType entity.MetricType, topK int, sp entity.SearchParam, opts ...SearchQueryOptionFunc) ([]SearchResult, error) {

there is a SearchQueryOptionFunc param, it can be use the WithSearchQueryConsistencyLevel method to get this param

// WithSearchQueryConsistencyLevel specifies consistency level
func WithSearchQueryConsistencyLevel(cl entity.ConsistencyLevel) SearchQueryOptionFunc {
	return func(option *SearchQueryOption) {
		option.ConsistencyLevel = cl
	}
}

from milvus.

here is the client api

func (c *GrpcClient) Search(ctx context.Context, collName string, partitions []string,
    expr string, outputFields []string, vectors []entity.Vector, vectorField string, metricType entity.MetricType, topK int, sp entity.SearchParam, opts ...SearchQueryOptionFunc) ([]SearchResult, error) {

there is a SearchQueryOptionFunc param, it can be use the WithSearchQueryConsistencyLevel method to get this param

// WithSearchQueryConsistencyLevel specifies consistency level
func WithSearchQueryConsistencyLevel(cl entity.ConsistencyLevel) SearchQueryOptionFunc {
	return func(option *SearchQueryOption) {
		option.ConsistencyLevel = cl
	}
}

I mean http api param name. ConsistencyLevel=Bounded? can you give me some example? use curl command

from milvus.

@dushulin you can try to use the attu to delete the data. And the http api currently does not support this parameter, because it's a new parameter.

from milvus.