diff --git a/src/raw/client.rs b/src/raw/client.rs index c1137df..4659385 100644 --- a/src/raw/client.rs +++ b/src/raw/client.rs @@ -3,7 +3,7 @@ use tikv_client_common::Error; use crate::{ - backoff::{DEFAULT_REGION_BACKOFF, OPTIMISTIC_BACKOFF}, + backoff::DEFAULT_REGION_BACKOFF, config::Config, pd::PdRpcClient, raw::lowering::*, @@ -115,7 +115,6 @@ impl Client { let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) .single_region() .await? - .resolve_lock(OPTIMISTIC_BACKOFF) .retry_region(DEFAULT_REGION_BACKOFF) .post_process_default() .plan(); @@ -146,7 +145,6 @@ impl Client { ) -> Result> { let request = new_raw_batch_get_request(keys.into_iter().map(Into::into), self.cf.clone()); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .merge(Collect) @@ -177,7 +175,6 @@ impl Client { let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) .single_region() .await? - .resolve_lock(OPTIMISTIC_BACKOFF) .retry_region(DEFAULT_REGION_BACKOFF) .extract_error() .plan(); @@ -208,7 +205,6 @@ impl Client { ) -> Result<()> { let request = new_raw_batch_put_request(pairs.into_iter().map(Into::into), self.cf.clone()); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .extract_error() @@ -239,7 +235,6 @@ impl Client { let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) .single_region() .await? - .resolve_lock(OPTIMISTIC_BACKOFF) .retry_region(DEFAULT_REGION_BACKOFF) .extract_error() .plan(); @@ -268,7 +263,6 @@ impl Client { let request = new_raw_batch_delete_request(keys.into_iter().map(Into::into), self.cf.clone()); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .extract_error() @@ -295,7 +289,6 @@ impl Client { pub async fn delete_range(&self, range: impl Into) -> Result<()> { let request = new_raw_delete_range_request(range.into(), self.cf.clone()); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .extract_error() @@ -437,7 +430,6 @@ impl Client { let request = new_raw_scan_request(range.into(), limit, key_only, self.cf.clone()); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .merge(Collect) @@ -469,7 +461,6 @@ impl Client { self.cf.clone(), ); let plan = crate::request::PlanBuilder::new(self.rpc.clone(), request) - .resolve_lock(OPTIMISTIC_BACKOFF) .multi_region() .retry_region(DEFAULT_REGION_BACKOFF) .merge(Collect)