Fix delete session key with prefix (#28267)

Signed-off-by: jaime <yun.zhang@zilliz.com>
pull/28274/head
jaime 2023-11-08 17:04:22 +08:00 committed by GitHub
parent 99350b1be4
commit 618c58db4e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions

View File

@ -225,7 +225,7 @@ func CleanSession(metaPath string, etcdEndpoints []string, sessionSuffix []strin
}
for _, key := range keys {
_, _ = etcdCli.Delete(ctx, key, clientv3.WithPrefix())
_, _ = etcdCli.Delete(ctx, key)
}
log.Info("clean sessions from etcd", zap.Any("keys", keys))
return nil