diff --git a/Cargo.lock b/Cargo.lock index 1122170df03e4..db421dd9ac45f 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -5053,6 +5053,15 @@ dependencies = [ "num-traits", ] +[[package]] +name = "float-cmp" +version = "0.10.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b09cf3155332e944990140d967ff5eceb70df778b34f77d8075db46e4704e6d8" +dependencies = [ + "num-traits", +] + [[package]] name = "flume" version = "0.11.0" @@ -9259,7 +9268,7 @@ source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "59230a63c37f3e18569bdb90e4a89cbf5bf8b06fea0b84e65ea10cc4df47addd" dependencies = [ "difflib", - "float-cmp", + "float-cmp 0.9.0", "itertools 0.10.5", "normalize-line-endings", "predicates-core", @@ -13456,13 +13465,12 @@ dependencies = [ [[package]] name = "simd-json" -version = "0.13.3" +version = "0.14.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "d123f285a3635e423ec2ef5b67e0168dcf86c0d62fffbcea88fcd1c926e47413" +checksum = "b1df0290e9bfe79ddd5ff8798ca887cd107b75353d2957efe9777296e17f26b5" dependencies = [ "getrandom", "halfbrown", - "lexical-core", "ref-cast", "serde", "serde_json", @@ -15375,11 +15383,11 @@ checksum = "5a84c137d37ab0142f0f2ddfe332651fdbf252e7b7dbb4e67b6c1f1b2e925101" [[package]] name = "value-trait" -version = "0.8.0" +version = "0.10.1" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "ea87257cfcbedcb9444eda79c59fdfea71217e6305afee8ee33f500375c2ac97" +checksum = "9170e001f458781e92711d2ad666110f153e4e50bfd5cbd02db6547625714187" dependencies = [ - "float-cmp", + "float-cmp 0.10.0", "halfbrown", "itoa", "ryu", diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml index d8733c9e505ea..9fd49fea88c7b 100644 --- a/src/connector/Cargo.toml +++ b/src/connector/Cargo.toml @@ -139,7 +139,7 @@ serde = { version = "1", features = ["derive", "rc"] } serde_derive = "1" serde_json = "1" serde_with = { version = "3", features = ["json"] } -simd-json = { version = "0.13.3", features = ["hints"] } +simd-json = { version = "0.14.2", features = ["hints"] } sqlx = { workspace = true } strum = "0.26" strum_macros = "0.26" diff --git a/src/connector/src/parser/common.rs b/src/connector/src/parser/common.rs index 102014966db42..68779080f0c8c 100644 --- a/src/connector/src/parser/common.rs +++ b/src/connector/src/parser/common.rs @@ -12,7 +12,7 @@ // See the License for the specific language governing permissions and // limitations under the License. -use simd_json::prelude::ValueAsContainer; +use simd_json::prelude::ValueAsObject; use simd_json::BorrowedValue; /// Get a value from a json object by key, case insensitive. diff --git a/src/connector/src/parser/unified/json.rs b/src/connector/src/parser/unified/json.rs index 8ee8f9fe9386f..3584e233d74a1 100644 --- a/src/connector/src/parser/unified/json.rs +++ b/src/connector/src/parser/unified/json.rs @@ -28,7 +28,7 @@ use risingwave_common::types::{ use risingwave_common::util::iter_util::ZipEqFast; use risingwave_connector_codec::decoder::utils::extract_decimal; use simd_json::prelude::{ - TypedValue, ValueAsContainer, ValueAsScalar, ValueObjectAccess, ValueTryAsScalar, + TypedValue, ValueAsArray, ValueAsScalar, ValueObjectAccess, ValueTryAsScalar, }; use simd_json::{BorrowedValue, ValueType}; use thiserror_ext::AsReport;