diff --git a/src/pipeline/src/etl/transform/transformer/greptime.rs b/src/pipeline/src/etl/transform/transformer/greptime.rs index fd2b43279e81..d9eaec292029 100644 --- a/src/pipeline/src/etl/transform/transformer/greptime.rs +++ b/src/pipeline/src/etl/transform/transformer/greptime.rs @@ -69,10 +69,9 @@ impl GreptimeTransformer { Some(val) => coerce_value(val, transform)?, None => { let default = transform.get_default(); - if default.is_some() { - coerce_value(default.unwrap(), transform)? - } else { - None + match default { + Some(default) => coerce_value(default, transform)?, + None => None, } } };