This is an automated email from the ASF dual-hosted git repository.
richox 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 711142f4 fix concat_ws null (#1728)
711142f4 is described below
commit 711142f4f3c9569a8103968ef789f60deb11c6ee
Author: cxzl25 <[email protected]>
AuthorDate: Thu Dec 11 12:56:51 2025 +0800
fix concat_ws null (#1728)
---
native-engine/datafusion-ext-functions/src/spark_strings.rs | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/native-engine/datafusion-ext-functions/src/spark_strings.rs
b/native-engine/datafusion-ext-functions/src/spark_strings.rs
index cbbff685..7e0cd4e4 100644
--- a/native-engine/datafusion-ext-functions/src/spark_strings.rs
+++ b/native-engine/datafusion-ext-functions/src/spark_strings.rs
@@ -218,11 +218,11 @@ pub fn string_concat_ws(args: &[ColumnarValue]) ->
Result<ColumnarValue> {
}
}
ColumnarValue::Scalar(scalar) => {
- if let ScalarValue::Utf8(s) = scalar {
- match s {
- Some(s) => return Ok(Arg::Literal(&s)),
- None => return Ok(Arg::Ignore),
- }
+ if scalar.is_null() {
+ return Ok(Arg::Ignore);
+ }
+ if let ScalarValue::Utf8(Some(s)) = scalar {
+ return Ok(Arg::Literal(&s));
}
if let ScalarValue::List(l) = scalar
&& l.data_type() == &DataType::Utf8
