fix(source): base64 decode bytes from JSON string

risingwavelabs · Dec 13, 2024 · 417a1c5 · 417a1c5
1 parent f1ac766
commit 417a1c5
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/connector/src/parser/unified/json.rs b/src/connector/src/parser/unified/json.rs
@@ -408,9 +408,11 @@ impl JsonParseOptions {
                     .get("value")
                     .ok_or_else(create_error)?
                     .as_str()
-                    .unwrap()
-                    .as_bytes();
-                let unscaled = BigInt::from_signed_bytes_be(value);
+                    .unwrap();
+                let value = base64::engine::general_purpose::STANDARD
+                    .decode(value)
+                    .map_err(|_| create_error())?;
+                let unscaled = BigInt::from_signed_bytes_be(&value);
                 let decimal = scaled_bigint_to_rust_decimal(unscaled, scale as _)?;
                 ScalarImpl::Decimal(Decimal::Normalized(decimal))
             }