From b066bf6669cd46fa23fccff034273dbb24fb993d Mon Sep 17 00:00:00 2001 From: xorsum Date: Mon, 30 Mar 2026 14:13:11 +0800 Subject: [PATCH] fix some typo --- native-engine/auron-jni-bridge/src/jni_bridge.rs | 2 +- native-engine/auron-planner/src/planner.rs | 4 ++-- .../datafusion-ext-plans/src/flink/serde/pb_deserializer.rs | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/native-engine/auron-jni-bridge/src/jni_bridge.rs b/native-engine/auron-jni-bridge/src/jni_bridge.rs index f9b5d030f..85b7598d3 100644 --- a/native-engine/auron-jni-bridge/src/jni_bridge.rs +++ b/native-engine/auron-jni-bridge/src/jni_bridge.rs @@ -89,7 +89,7 @@ macro_rules! jni_map_error_with_env { Err($crate::jni_bridge::jni::errors::Error::JavaException) => { let ex = $env .exception_occurred() - .expect("failed to obtain pending Java execption object"); + .expect("failed to obtain pending Java exception object"); $env.exception_describe() .expect("failed to print Java exception to stderr"); $env.exception_clear() diff --git a/native-engine/auron-planner/src/planner.rs b/native-engine/auron-planner/src/planner.rs index 68c7b6a47..254c32f02 100644 --- a/native-engine/auron-planner/src/planner.rs +++ b/native-engine/auron-planner/src/planner.rs @@ -1066,7 +1066,7 @@ impl PhysicalPlanner { input: &Arc, sort: &Box, ) -> Result, PlanSerDeError> { - let pyhsical_sort_expr = sort + let physical_sort_expr = sort .expr .iter() .map(|expr| { @@ -1099,7 +1099,7 @@ impl PhysicalPlanner { } }) .collect::, _>>()?; - Ok(pyhsical_sort_expr) + Ok(physical_sort_expr) } pub fn parse_protobuf_partitioning( diff --git a/native-engine/datafusion-ext-plans/src/flink/serde/pb_deserializer.rs b/native-engine/datafusion-ext-plans/src/flink/serde/pb_deserializer.rs index 4b74a4f2a..06bd852e5 100644 --- a/native-engine/datafusion-ext-plans/src/flink/serde/pb_deserializer.rs +++ b/native-engine/datafusion-ext-plans/src/flink/serde/pb_deserializer.rs @@ -170,7 +170,7 @@ impl PbDeserializer { nested_msg_mapping.clone(), &skip_fields, ) - .expect("Failed to transfer output scheam to pb scheam"); + .expect("Failed to transfer output schema to pb schema"); let tag_to_output_mapping = create_tag_to_output_mapping(message_descriptor.clone(), &pb_schema);