Refresh etcd source config with Searializable option (#23954)

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
This commit is contained in:
congqixia 2023-05-09 11:52:40 +08:00 committed by GitHub
parent f6d3b4f7ac
commit de4b4dafef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -133,7 +133,7 @@ func (es *EtcdSource) refreshConfigurations() error {
ctx, cancel := context.WithTimeout(es.ctx, ReadConfigTimeout) ctx, cancel := context.WithTimeout(es.ctx, ReadConfigTimeout)
defer cancel() defer cancel()
response, err := es.etcdCli.Get(ctx, prefix, clientv3.WithPrefix()) response, err := es.etcdCli.Get(ctx, prefix, clientv3.WithPrefix(), clientv3.WithSerializable())
if err != nil { if err != nil {
return err return err
} }