mirror of https://github.com/milvus-io/milvus.git
Fix delete session key with prefix (#28260)
Signed-off-by: jaime <yun.zhang@zilliz.com>pull/28271/head
parent
f4341f254d
commit
ec0d9d8fd4
|
@ -225,7 +225,7 @@ func CleanSession(metaPath string, etcdEndpoints []string, sessionSuffix []strin
|
||||||
}
|
}
|
||||||
|
|
||||||
for _, key := range keys {
|
for _, key := range keys {
|
||||||
_, _ = etcdCli.Delete(ctx, key, clientv3.WithPrefix())
|
_, _ = etcdCli.Delete(ctx, key)
|
||||||
}
|
}
|
||||||
log.Info("clean sessions from etcd", zap.Any("keys", keys))
|
log.Info("clean sessions from etcd", zap.Any("keys", keys))
|
||||||
return nil
|
return nil
|
||||||
|
|
Loading…
Reference in New Issue