This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 17e14e9a63 [bug](udaf) fix java udaf incorrect get null value with row
(#15151)
17e14e9a63 is described below
commit 17e14e9a63b37cdd5a8327e057bea04cdc120908
Author: zhangstar333 <87313068+zhangstar...@users.noreply.github.com>
AuthorDate: Mon Dec 19 10:07:12 2022 +0800
[bug](udaf) fix java udaf incorrect get null value with row (#15151)
---
fe/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/fe/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java
b/fe/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java
index 598886a26b..f684363bf6 100644
--- a/fe/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java
+++ b/fe/java-udf/src/main/java/org/apache/doris/udf/UdafExecutor.java
@@ -361,7 +361,8 @@ public class UdafExecutor {
for (int i = 0; i < argTypes.length; ++i) {
// skip the input column of current row is null
if (UdfUtils.UNSAFE.getLong(null,
UdfUtils.getAddressAtOffset(inputNullsPtrs, i)) != -1
- && UdfUtils.UNSAFE.getByte(null,
UdfUtils.getAddressAtOffset(inputNullsPtrs, i) + row) == 1) {
+ && (UdfUtils.UNSAFE.getByte(null,
UdfUtils.UNSAFE.getLong(null,
+ UdfUtils.getAddressAtOffset(inputNullsPtrs, i)) + row) ==
1)) {
inputObjects[i] = null;
continue;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
