diff --git a/src/meta-srv/src/service/store/etcd.rs b/src/meta-srv/src/service/store/etcd.rs index 04f82c4672..55cebce8bd 100644 --- a/src/meta-srv/src/service/store/etcd.rs +++ b/src/meta-srv/src/service/store/etcd.rs @@ -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::>(); + 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::>(); + 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