This is an automated email from the ASF dual-hosted git repository.

csy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/auron.git


The following commit(s) were added to refs/heads/master by this push:
     new 45596278 [AURON #2138] Fix some typos in native (#2139)
45596278 is described below

commit 455962782b0a94c85bd93c60f949baef7e098b42
Author: bkhan <[email protected]>
AuthorDate: Mon Mar 30 15:08:53 2026 +0800

    [AURON #2138] Fix some typos in native (#2139)
    
    # Which issue does this PR close?
    
    Closes #2138
    
    # Rationale for this change
    
    # What changes are included in this PR?
    
    # Are there any user-facing changes?
    
    # How was this patch tested?
---
 native-engine/auron-jni-bridge/src/jni_bridge.rs                      | 2 +-
 native-engine/auron-planner/src/planner.rs                            | 4 ++--
 native-engine/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 f9b5d030..85b7598d 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 68c7b6a4..254c32f0 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<dyn ExecutionPlan>,
         sort: &Box<SortExecNode>,
     ) -> Result<Vec<PhysicalSortExpr>, PlanSerDeError> {
-        let pyhsical_sort_expr = sort
+        let physical_sort_expr = sort
             .expr
             .iter()
             .map(|expr| {
@@ -1099,7 +1099,7 @@ impl PhysicalPlanner {
                 }
             })
             .collect::<Result<Vec<_>, _>>()?;
-        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 4b74a4f2..06bd852e 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);

Reply via email to