diff --git a/plugins/sql/src/decode/postgres.rs b/plugins/sql/src/decode/postgres.rs index 0b4430e3..39c9acfd 100644 --- a/plugins/sql/src/decode/postgres.rs +++ b/plugins/sql/src/decode/postgres.rs @@ -17,7 +17,7 @@ pub(crate) fn to_json(v: PgValueRef) -> Result { JsonValue::Null } } - "FLOAT$" | "FLOAT8" => { + "FLOAT4" | "FLOAT8" => { if let Ok(v) = ValueRef::to_owned(&v).try_decode::() { JsonValue::from(v) } else {