chore: fix typo

GreptimeTeam · Jul 25, 2024 · 0a14c6e · 0a14c6e
1 parent 049d426
commit 0a14c6e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/pipeline/src/etl/processor.rs b/src/pipeline/src/etl/processor.rs
@@ -239,7 +239,7 @@ impl std::ops::DerefMut for Processors {
 }
 
 impl Processors {
-    /// A collection of all the processor's requied input fields
+    /// A collection of all the processor's required input fields
     pub fn required_keys(&self) -> &Vec<String> {
         &self.required_keys
     }

diff --git a/src/pipeline/src/etl/transform/transformer/greptime.rs b/src/pipeline/src/etl/transform/transformer/greptime.rs
@@ -154,9 +154,9 @@ impl Transformer for GreptimeTransformer {
             0 => {
                 transforms.push(GreptimeTransformer::default_greptime_timestamp_column());
 
-                let requied_keys = transforms.required_keys_mut();
-                requied_keys.push(DEFAULT_GREPTIME_TIMESTAMP_COLUMN.to_string());
-                requied_keys.sort();
+                let required_keys = transforms.required_keys_mut();
+                required_keys.push(DEFAULT_GREPTIME_TIMESTAMP_COLUMN.to_string());
+                required_keys.sort();
 
                 let output_keys = transforms.output_keys_mut();
                 output_keys.push(DEFAULT_GREPTIME_TIMESTAMP_COLUMN.to_string());