You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ya...@apache.org on 2025/09/01 03:38:57 UTC
(spark) branch master updated: [SPARK-53437][SQL] InterpretedUnsafeProjection shall setNull4Bytes for YearMonthIntervalType field
This is an automated email from the ASF dual-hosted git repository.
yao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git
The following commit(s) were added to refs/heads/master by this push:
new 1485295a6e49 [SPARK-53437][SQL] InterpretedUnsafeProjection shall setNull4Bytes for YearMonthIntervalType field
1485295a6e49 is described below
commit 1485295a6e49df0e21dbe29a4cc2f8d9d1ec54f5
Author: Kent Yao <ya...@apache.org>
AuthorDate: Mon Sep 1 11:38:45 2025 +0800
[SPARK-53437][SQL] InterpretedUnsafeProjection shall setNull4Bytes for YearMonthIntervalType field
### What changes were proposed in this pull request?
InterpretedUnsafeProjection shall setNull4Bytes for a YearMonthIntervalType field instead of setNull8Bytes
### Why are the changes needed?
YearMonthIntervalType is 4-byte length
### Does this PR introduce _any_ user-facing change?
'No'.
### How was this patch tested?
Passing CI
### Was this patch authored or co-authored using generative AI tooling?
no
Closes #52178 from yaooqinn/SPARK-53437.
Authored-by: Kent Yao <ya...@apache.org>
Signed-off-by: Kent Yao <ya...@apache.org>
---
.../spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala
index 46e92e0f38e2..004cd576ace0 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/InterpretedUnsafeProjection.scala
@@ -268,7 +268,7 @@ object InterpretedUnsafeProjection {
writer.setNull2Bytes(i)
}
}
- case IntegerType | DateType | FloatType =>
+ case IntegerType | DateType | FloatType | _: YearMonthIntervalType =>
(v, i) => {
if (!v.isNullAt(i)) {
unsafeWriter(v, i)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org