We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1e05ff4 commit 12f4c9eCopy full SHA for 12f4c9e
spark/src/main/scala/org/apache/comet/serde/literals.scala
@@ -132,7 +132,9 @@ object CometLiteral extends CometExpressionSerde[Literal] with Logging {
132
case ByteType =>
133
array.foreach(v => {
134
val casted = v.asInstanceOf[lang.Byte]
135
- listLiteralBuilder.addByteValues(casted.intValue())
+ listLiteralBuilder.addByteValues(
136
+ if (casted != null) casted.intValue()
137
+ else null.asInstanceOf[Integer])
138
listLiteralBuilder.addNullMask(casted != null)
139
})
140
case ShortType =>
0 commit comments