chore: remove repetitive words (#3469)

remove repetitive words

Signed-off-by: gcmutator <329964069@qq.com>

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
 

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))

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;
 

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()),

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()
     }

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],

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<()> {