chore: fix some meta typo (#18824)

Author: forsaken628

.typos.toml

@@ -1,39 +1,58 @@
 # If there are words that you think should not be treated as typo.
 # Please list here along with a comment.
+
+[default]
+extend-ignore-re = [
+    "(?Rm)^.*(#|//)\\s*typos:disable-line$",
+    "(#|//)\\s*typos:ignore-next-line\\n.*",
+    "(?s)(#|//)\\s*typos:off.*?\\n\\s*(#|//)\\s*typos:on",
+]
+
 [default.extend-words]
 # Preserved for NdJson
-"Nd" = "Nd"
-# Microsoft K8s Server
-"AKS" = "AKS"
+Nd = "Nd"
+typ = "typ"
+aranges = "aranges"
+
+[default.extend-identifiers]
+
 # Wrong cases
-"ba" = "ba"
-"ue" = "ue"
-"INOUT" = "INOUT"
-"ser" = "ser"
-"Ser" = "Ser"
-"flate" = "flate"
-"Tke" = "Tke"
-"typ" = "typ"
-"dows" = "dows"
-# created_ons & updated_ons
-"ons" = "ons"
-
-# Intentional typos used in SQL error suggestion test cases
-"tabl" = "tabl"
-"optmize" = "optmize" 
-"vacum" = "vacum"
-"creat" = "creat"
-"crate" = "crate"
+Tke = "Tke"
+ba = "ba"
+
+# sql function name: diff_dows, between_dows
+diff_dows = "diff_dows"
+between_dows = "between_dows"
+
+into_flate2 = "into_flate2"
 
 [files]
 extend-exclude = [
     "**/Cargo.toml",
-    "scripts/benchmark/",
     "benchmark/",
-    "tests/",
-    "src/meta",
-    # masked secrets
-    "src/query/config/src/mask.rs",
-    # Forked from upstream
-    "src/common/parquet2"
+    "tests/sqllogictests",
+    "tests/nox/java_client/testng.xml",
+    "tests/data/ddl",
 ]
+
+# todo: fix me
+[type.py]
+check-file = false
+
+# todo: fix me
+[type.sh]
+check-file = false
+
+[type.txt]
+check-file = false
+
+[type.sql]
+check-file = false
+
+[type.csr]
+extend-glob = ["*.csr"]
+check-file = false
+
+[type.result]
+extend-glob = ["*.result"]
+check-file = false

src/common/hashtable/src/utils.rs

@@ -234,7 +234,7 @@ pub struct MergeIntoBlockInfoIndex {
 pub type Interval = (u32, u32);
 
 /// the segment blocks are not sequential,because we do parallel hashtable build.
-/// the block lay out in chunks could be like belows:
+/// the block lay out in chunks could be like bellows:
 /// segment0_block1 |
 /// segment1_block0 |  chunk0
 /// segment0_block0 |

src/common/io/tests/it/main.rs

@@ -24,4 +24,4 @@ mod borsh_serialization;
 mod cursor_ext;
 mod escape;
 mod interval;
-mod serialization_format_compatability;
+mod serialization_format_compatibility;

…it/serialization_format_compatability.rs …it/serialization_format_compatibility.rssrc/common/io/tests/it/serialization_format_compatability.rs renamed to src/common/io/tests/it/serialization_format_compatibility.rs src/common/io/tests/it/serialization_format_compatability.rs renamed to src/common/io/tests/it/serialization_format_compatibility.rs

@@ -129,7 +129,7 @@ async fn remove_copied_files_for_dropped_table(
     // Loop until:
     // - all cleaned
     // - or table is removed from meta-service
-    // - or is no longer in `droppped` state.
+    // - or is no longer in `dropped` state.
     for i in 0..usize::MAX {
         let mut txn = TxnRequest::default();
 

src/meta/api/src/garbage_collection_api.rs

@@ -559,7 +559,7 @@ mod tests {
         ) -> Result<KVStream<Self::Error>, Self::Error> {
             let mut res = Vec::with_capacity(keys.len());
             for (i, key) in keys.iter().enumerate() {
-                // For tesing early return stream.
+                // For testing early return stream.
                 if let Some(early_return) = self.early_return {
                     if i >= early_return {
                         break;

src/meta/api/src/kv_pb_api/mod.rs

@@ -2714,7 +2714,7 @@ impl SchemaApiTestSuite {
                 // Change the comment, this modification should not be committed
                 req.new_table_meta.comment = "some new comment".to_string();
                 // Expects no KV api level error, and no app level error.
-                // For the convenience of reviewing, using explict type signature
+                // For the convenience of reviewing, using explicit type signature
                 let _r: databend_common_meta_app::schema::UpdateTableMetaReply = mt
                     .update_multi_table_meta_with_sender(
                         UpdateMultiTableMetaReq {
@@ -5526,7 +5526,7 @@ impl SchemaApiTestSuite {
             let handle = runtime.spawn(async move {
                 let resp = arc_mt.create_table(create_table_req.clone()).await;
 
-                // assert that when create table concurrently with corret params return error,
+                // assert that when create table concurrently with correct params return error,
                 // the error MUST be TxnRetryMaxTimes
                 if resp.is_err() {
                     assert!(matches!(
@@ -5547,7 +5547,7 @@ impl SchemaApiTestSuite {
                 };
                 let resp = arc_mt.commit_table_meta(commit_table_req).await;
 
-                // assert that when commit_table_meta concurrently with corret params return error,
+                // assert that when commit_table_meta concurrently with correct params return error,
                 // the error MUST be TxnRetryMaxTimes or CommitTableMetaError(prev table id has been changed)
                 if resp.is_err() {
                     assert!(

src/meta/api/src/schema_api_test_suite.rs

@@ -71,7 +71,7 @@ impl Display for ProcedureMeta {
     fn fmt(&self, f: &mut Formatter) -> fmt::Result {
         write!(
             f,
-            "Lanuage: {:?}, args {} return_type: {}, CreatedOn: {:?}, Script: {}, Comment: {:?}",
+            "Language: {:?}, args {} return_type: {}, CreatedOn: {:?}, Script: {}, Comment: {:?}",
             self.procedure_language,
             self.arg_names.display_n(1000),
             self.return_types.display_n(1000),

src/meta/app/src/principal/procedure.rs

@@ -137,7 +137,7 @@ pub struct TableStatistics {
     pub number_of_blocks: Option<u64>,
 }
 
-/// Iceberg table parition
+/// Iceberg table partition
 #[derive(serde::Serialize, serde::Deserialize, Clone, Debug, Eq, PartialEq)]
 pub enum TablePartition {
     Identity { columns: Vec<String> },

src/meta/app/src/schema/table/mod.rs

@@ -440,7 +440,7 @@ impl MetaGrpcClient {
         resp_err: Option<&(dyn std::error::Error + 'static)>,
     ) {
         // TODO: this current endpoint is not stable, may be modified by other thread.
-        //       The caller should pasing the in use endpoint.
+        //       The caller should passing the in use endpoint.
         let current_endpoint = self.get_current_endpoint();
 
         let Some(endpoint) = current_endpoint else {