[bug](udaf) fix java udaf incorrect get null value with row (apache#1…

…5151)
JackDrogon · Dec 19, 2022 · 17e14e9 · 17e14e9
1 parent 8a08085
commit 17e14e9
Showing 1 changed file with 2 additions and 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
@@ -361,7 +361,8 @@ private Object[] allocateInputObjects(long row) throws UdfRuntimeException {
         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;
             }