From 21ff3620bea43818b5aacf669b548e4f3f91e43b Mon Sep 17 00:00:00 2001
From: gcmutator <134900551+gcmutator@users.noreply.github.com>
Date: Sat, 9 Mar 2024 12:18:47 +0800
Subject: [PATCH] chore: remove repetitive words (#3469)

remove repetitive words

Signed-off-by: gcmutator <329964069@qq.com>
---
 docs/rfcs/2023-05-09-distributed-planner.md  | 2 +-
 src/common/macro/src/admin_fn.rs             | 2 +-
 src/common/procedure/src/local/runner.rs     | 2 +-
 src/flow/src/expr/linear.rs                  | 2 +-
 src/mito2/src/cache.rs                       | 2 +-
 src/promql/src/functions/extrapolate_rate.rs | 2 +-
 src/store-api/src/region_request.rs          | 2 +-
 7 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/docs/rfcs/2023-05-09-distributed-planner.md b/docs/rfcs/2023-05-09-distributed-planner.md
index 8d277de00d..f43c356004 100644
--- a/docs/rfcs/2023-05-09-distributed-planner.md
+++ b/docs/rfcs/2023-05-09-distributed-planner.md
@@ -79,7 +79,7 @@ This RFC proposes to add a new expression node `MergeScan` to merge result from
 │               │    │                             │
 └─Frontend──────┘    └─Remote-Sources──────────────┘
 ```
-This merge operation simply chains all the the underlying remote data sources and return `RecordBatch`, just like a coalesce op. And each remote sources is a gRPC query to datanode via the substrait logical plan interface. The plan is transformed and divided from the original query that comes to frontend.
+This merge operation simply chains all the underlying remote data sources and return `RecordBatch`, just like a coalesce op. And each remote sources is a gRPC query to datanode via the substrait logical plan interface. The plan is transformed and divided from the original query that comes to frontend.
 
 ## Commutativity of MergeScan
 
diff --git a/src/common/macro/src/admin_fn.rs b/src/common/macro/src/admin_fn.rs
index c6452ec060..3faa06d933 100644
--- a/src/common/macro/src/admin_fn.rs
+++ b/src/common/macro/src/admin_fn.rs
@@ -32,7 +32,7 @@ macro_rules! ok {
     };
 }
 
-/// Internal util macro to to create an error.
+/// Internal util macro to create an error.
 macro_rules! error {
     ($span:expr, $msg: expr) => {
         Err(syn::Error::new($span, $msg))
diff --git a/src/common/procedure/src/local/runner.rs b/src/common/procedure/src/local/runner.rs
index ef4e018de2..b787fbf77e 100644
--- a/src/common/procedure/src/local/runner.rs
+++ b/src/common/procedure/src/local/runner.rs
@@ -152,7 +152,7 @@ impl Runner {
             guard.key_guards.push(key_guard);
         }
 
-        // Execute the procedure. We need to release the lock whenever the the execution
+        // Execute the procedure. We need to release the lock whenever the execution
         // is successful or fail.
         self.execute_procedure_in_loop().await;
 
diff --git a/src/flow/src/expr/linear.rs b/src/flow/src/expr/linear.rs
index 830195f5b2..331b883996 100644
--- a/src/flow/src/expr/linear.rs
+++ b/src/flow/src/expr/linear.rs
@@ -800,7 +800,7 @@ mod test {
             .unwrap();
         // only retain sum result
         let mfp = mfp.project(vec![4]).unwrap();
-        // accept only if if the sum is greater than 10
+        // accept only if the sum is greater than 10
         let mfp = mfp
             .filter(vec![ScalarExpr::Column(0).call_binary(
                 ScalarExpr::Literal(Value::from(10i32), ConcreteDataType::int32_datatype()),
diff --git a/src/mito2/src/cache.rs b/src/mito2/src/cache.rs
index d0707e1bae..33e72e1b70 100644
--- a/src/mito2/src/cache.rs
+++ b/src/mito2/src/cache.rs
@@ -158,7 +158,7 @@ impl CacheManager {
         }
     }
 
-    /// Gets the the write cache.
+    /// Gets the write cache.
     pub(crate) fn write_cache(&self) -> Option<&WriteCacheRef> {
         self.write_cache.as_ref()
     }
diff --git a/src/promql/src/functions/extrapolate_rate.rs b/src/promql/src/functions/extrapolate_rate.rs
index 0506886be3..ea0c3f2a95 100644
--- a/src/promql/src/functions/extrapolate_rate.rs
+++ b/src/promql/src/functions/extrapolate_rate.rs
@@ -429,7 +429,7 @@ mod test {
             ts_range,
             value_range,
             timestamps,
-            // that two `2.0` is because `duration_to_start` are shrunk to to
+            // that two `2.0` is because `duration_to_start` are shrunk to
             // `duration_to_zero`, and causes `duration_to_zero` less than
             // `extrapolation_threshold`.
             vec![2.0, 1.5, 1.5, 1.5, 2.0, 1.5, 1.5, 1.5],
diff --git a/src/store-api/src/region_request.rs b/src/store-api/src/region_request.rs
index ce22a29027..a2ccee682e 100644
--- a/src/store-api/src/region_request.rs
+++ b/src/store-api/src/region_request.rs
@@ -353,7 +353,7 @@ pub enum AlterKind {
 }
 
 impl AlterKind {
-    /// Returns an error if the the alter kind is invalid.
+    /// Returns an error if the alter kind is invalid.
     ///
     /// It allows adding column if not exists and dropping column if exists.
     pub fn validate(&self, metadata: &RegionMetadata) -> Result<()> {