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);