diff --git a/src/pipeline/src/etl/processor/mod.rs b/src/pipeline/src/etl/processor/mod.rs
index 319b15cae3..390538098a 100644
--- a/src/pipeline/src/etl/processor/mod.rs
+++ b/src/pipeline/src/etl/processor/mod.rs
@@ -182,7 +182,7 @@ fn parse_processor(doc: &yaml_rust::Yaml) -> Result<Arc<dyn Processor>, String>
 
 pub(crate) fn yaml_string(v: &yaml_rust::Yaml, field: &str) -> Result<String, String> {
     v.as_str()
-        .map(|s| s.trim().to_string())
+        .map(|s| s.to_string())
         .ok_or(format!("'{field}' must be a string"))
 }
 
diff --git a/src/script/src/python/rspython/builtins/test.rs b/src/script/src/python/rspython/builtins/test.rs
index f7b9c851e0..a108663ad7 100644
--- a/src/script/src/python/rspython/builtins/test.rs
+++ b/src/script/src/python/rspython/builtins/test.rs
@@ -39,7 +39,7 @@ use crate::python::utils::format_py_error;
 #[test]
 fn convert_scalar_to_py_obj_and_back() {
     rustpython_vm::Interpreter::with_init(Default::default(), |vm| {
-        // this can be in `.enter()` closure, but for clearity, put it in the `with_init()`
+        // this can be in `.enter()` closure, but for clarity, put it in the `with_init()`
         let _ = PyVector::make_class(&vm.ctx);
     })
     .enter(|vm| {
@@ -422,7 +422,7 @@ fn test_vm() {
 
     rustpython_vm::Interpreter::with_init(Default::default(), |vm| {
         vm.add_native_module("udf_builtins", Box::new(greptime_builtin::make_module));
-        // this can be in `.enter()` closure, but for clearity, put it in the `with_init()`
+        // this can be in `.enter()` closure, but for clarity, put it in the `with_init()`
         let _ = PyVector::make_class(&vm.ctx);
     })
     .enter(|vm| {