rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-08 14:22:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: add etcd batch size warn

Browse Source
This commit is contained in:
shuiyisong
2023-06-20 15:06:29 +08:00
parent 8ed834b343
commit f2dd677501
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/meta-srv/src/service/store/etcd.rs
View File

@@ -142,6 +142,9 @@ impl KvStore for EtcdStore {
.into_iter()
.map(|k| TxnOp::get(k, options.clone()))
.collect();
if get_ops.len() > 128 {
warn!("batch_get too large, size: {}", get_ops.len());
}
let txn = Txn::new().and_then(get_ops);
let txn_res = self
@@ -185,6 +188,9 @@ impl KvStore for EtcdStore {
.into_iter()
.map(|kv| (TxnOp::put(kv.key, kv.value, options.clone())))
.collect::<Vec<_>>();
if put_ops.len() > 128 {
warn!("batch_put too large, size: {}", put_ops.len());
}
let txn = Txn::new().and_then(put_ops);
let txn_res = self
@@ -232,6 +238,9 @@ impl KvStore for EtcdStore {
.into_iter()
.map(|k| TxnOp::delete(k, options.clone()))
.collect::<Vec<_>>();
if delete_ops.len() > 128 {
warn!("batch_delete too large, size: {}", delete_ops.len());
}
let txn = Txn::new().and_then(delete_ops);
let txn_res = self