[HSTACK] - fix array_has returning false instead of NULL on empty array

aditanase · ccciudatu · commit 7ced8d058848 · 2025-07-23T11:12:17.000+03:00
diff --git a/datafusion/functions-nested/src/array_has.rs b/datafusion/functions-nested/src/array_has.rs
@@ -269,6 +269,8 @@ fn array_has_dispatch_for_scalar<O: OffsetSizeTrait>(
     let values = haystack.values();
     let is_nested = values.data_type().is_nested();
     let offsets = haystack.value_offsets();
+    let nulls = haystack.nulls();
+
     // If first argument is empty list (second argument is non-null), return false
     // i.e. array_has([], non-null element) -> false
     if values.is_empty() {
@@ -283,9 +285,15 @@ fn array_has_dispatch_for_scalar<O: OffsetSizeTrait>(
         let start = offset[0].to_usize().unwrap();
         let end = offset[1].to_usize().unwrap();
         let length = end - start;
-        // For non-nested list, length is 0 for null
+        // For non-nested list, check null vs empty
+        // otherwise array_has on [] returns null instead of false
         if length == 0 {
-            continue;
+            if let Some(nulls) = nulls {
+                if nulls.is_null(i) {
+                    continue;
+                }
+            }
+            final_contained[i] = Some(false);
         }
         let sliced_array = eq_array.slice(start, length);
         final_contained[i] = Some(sliced_array.true_count() > 0);
diff --git a/datafusion/sqllogictest/test_files/array.slt b/datafusion/sqllogictest/test_files/array.slt
@@ -63,6 +63,7 @@ AS VALUES
   (make_array(make_array(5, 6),make_array(7, 8)), make_array(7.7, 8.8, 9.9), make_array('d', NULL, 'l', 'o', 'r')),
   (make_array(make_array(7, NULL),make_array(9, 10)), make_array(10.1, NULL, 12.2), make_array('s', 'i', 't')),
   (NULL, make_array(13.3, 14.4, 15.5), make_array('a', 'm', 'e', 't')),
+  (NULL, make_array(), make_array('a', 'm', 'e', 't')),
   (make_array(make_array(11, 12),make_array(13, 14)), NULL, make_array(',')),
   (make_array(make_array(15, 16),make_array(NULL, 18)), make_array(16.6, 17.7, 18.8), NULL)
 ;
@@ -709,6 +710,7 @@ List(Field { name: "item", data_type: List(Field { name: "item", data_type: Int6
 List(Field { name: "item", data_type: List(Field { name: "item", data_type: Int64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Float64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} })
 List(Field { name: "item", data_type: List(Field { name: "item", data_type: Int64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Float64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} })
 List(Field { name: "item", data_type: List(Field { name: "item", data_type: Int64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Float64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} })
+List(Field { name: "item", data_type: List(Field { name: "item", data_type: Int64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }), nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Float64, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} }) List(Field { name: "item", data_type: Utf8, nullable: true, dict_id: 0, dict_is_ordered: false, metadata: {} })
 
 # arrays table
 query ???
@@ -719,6 +721,7 @@ select column1, column2, column3 from arrays;
 [[5, 6], [7, 8]] [7.7, 8.8, 9.9] [d, NULL, l, o, r]
 [[7, NULL], [9, 10]] [10.1, NULL, 12.2] [s, i, t]
 NULL [13.3, 14.4, 15.5] [a, m, e, t]
+NULL [] [a, m, e, t]
 [[11, 12], [13, 14]] NULL [,]
 [[15, 16], [NULL, 18]] [16.6, 17.7, 18.8] NULL
 
@@ -844,6 +847,7 @@ select column1[2], column2[3], column3[1] from arrays;
 [7, 8] 9.9 d
 [9, 10] 12.2 s
 NULL 15.5 a
+NULL NULL a
 [13, 14] NULL ,
 [NULL, 18] 18.8 NULL
 
@@ -858,6 +862,7 @@ NULL NULL NULL
 NULL NULL NULL
 NULL NULL NULL
 NULL NULL NULL
+NULL NULL NULL
 
 # single index with columns #3 (negative index)
 query ?RT
@@ -868,6 +873,7 @@ select column1[-2], column2[-3], column3[-1] from arrays;
 [5, 6] 7.7 r
 [7, NULL] 10.1 t
 NULL 13.3 t
+NULL NULL t
 [11, 12] NULL ,
 [15, 16] 16.6 NULL
 
@@ -880,6 +886,7 @@ select column1[9 - 7], column2[2 * 0], column3[1 - 3] from arrays;
 [7, 8] NULL o
 [9, 10] NULL i
 NULL NULL e
+NULL NULL e
 [13, 14] NULL NULL
 [NULL, 18] NULL NULL
 
@@ -951,6 +958,7 @@ select column1[2:4], column2[1:4], column3[3:4] from arrays;
 [[7, 8]] [7.7, 8.8, 9.9] [l, o]
 [[9, 10]] [10.1, NULL, 12.2] [t]
 NULL [13.3, 14.4, 15.5] [e, t]
+NULL [] [e, t]
 [[13, 14]] NULL []
 [[NULL, 18]] [16.6, 17.7, 18.8] NULL
 
@@ -963,6 +971,7 @@ select column1[0:5], column2[0:3], column3[0:9] from arrays;
 [[5, 6], [7, 8]] [7.7, 8.8, 9.9] [d, NULL, l, o, r]
 [[7, NULL], [9, 10]] [10.1, NULL, 12.2] [s, i, t]
 NULL [13.3, 14.4, 15.5] [a, m, e, t]
+NULL [] [a, m, e, t]
 [[11, 12], [13, 14]] NULL [,]
 [[15, 16], [NULL, 18]] [16.6, 17.7, 18.8] NULL
 
@@ -1027,6 +1036,7 @@ select column1[2:4:2], column2[1:4:2], column3[3:4:2] from arrays;
 [[7, 8]] [7.7, 9.9] [l]
 [[9, 10]] [10.1, 12.2] [t]
 NULL [13.3, 15.5] [e]
+NULL [] [e]
 [[13, 14]] NULL []
 [[NULL, 18]] [16.6, 18.8] NULL
 
@@ -1039,6 +1049,7 @@ select column1[0:5:2], column2[0:3:2], column3[0:9:2] from arrays;
 [[5, 6]] [7.7, 9.9] [d, l, r]
 [[7, NULL]] [10.1, 12.2] [s, t]
 NULL [13.3, 15.5] [a, e]
+NULL [] [a, e]
 [[11, 12]] NULL [,]
 [[15, 16]] [16.6, 18.8] NULL
 
@@ -2645,6 +2656,7 @@ select array_append(column2, 100.1), array_append(column3, '.') from arrays;
 [7.7, 8.8, 9.9, 100.1] [d, NULL, l, o, r, .]
 [10.1, NULL, 12.2, 100.1] [s, i, t, .]
 [13.3, 14.4, 15.5, 100.1] [a, m, e, t, .]
+[100.1] [a, m, e, t, .]
 [100.1] [,, .]
 [16.6, 17.7, 18.8, 100.1] [.]
 
@@ -2656,6 +2668,7 @@ select array_append(column2, 100.1), array_append(column3, '.') from large_array
 [7.7, 8.8, 9.9, 100.1] [d, NULL, l, o, r, .]
 [10.1, NULL, 12.2, 100.1] [s, i, t, .]
 [13.3, 14.4, 15.5, 100.1] [a, m, e, t, .]
+[100.1] [a, m, e, t, .]
 [100.1] [,, .]
 [16.6, 17.7, 18.8, 100.1] [.]
 
@@ -2903,6 +2916,7 @@ select array_prepend(100.1, column2), array_prepend('.', column3) from arrays;
 [100.1, 7.7, 8.8, 9.9] [., d, NULL, l, o, r]
 [100.1, 10.1, NULL, 12.2] [., s, i, t]
 [100.1, 13.3, 14.4, 15.5] [., a, m, e, t]
+[100.1] [., a, m, e, t]
 [100.1] [., ,]
 [100.1, 16.6, 17.7, 18.8] [.]
 
@@ -2914,6 +2928,7 @@ select array_prepend(100.1, column2), array_prepend('.', column3) from large_arr
 [100.1, 7.7, 8.8, 9.9] [., d, NULL, l, o, r]
 [100.1, 10.1, NULL, 12.2] [., s, i, t]
 [100.1, 13.3, 14.4, 15.5] [., a, m, e, t]
+[100.1] [., a, m, e, t]
 [100.1] [., ,]
 [100.1, 16.6, 17.7, 18.8] [.]
 
@@ -3275,6 +3290,7 @@ select array_concat(column1, column1), array_concat(column2, column2), array_con
 [[5, 6], [7, 8], [5, 6], [7, 8]] [7.7, 8.8, 9.9, 7.7, 8.8, 9.9] [d, NULL, l, o, r, d, NULL, l, o, r]
 [[7, NULL], [9, 10], [7, NULL], [9, 10]] [10.1, NULL, 12.2, 10.1, NULL, 12.2] [s, i, t, s, i, t]
 NULL [13.3, 14.4, 15.5, 13.3, 14.4, 15.5] [a, m, e, t, a, m, e, t]
+NULL [] [a, m, e, t, a, m, e, t]
 [[11, 12], [13, 14], [11, 12], [13, 14]] NULL [,, ,]
 [[15, 16], [NULL, 18], [15, 16], [NULL, 18]] [16.6, 17.7, 18.8, 16.6, 17.7, 18.8] NULL
 
@@ -3287,6 +3303,7 @@ select array_concat(column1, make_array(make_array(1, 2), make_array(3, 4))), ar
 [[5, 6], [7, 8], [1, 2], [3, 4]] [7.7, 8.8, 9.9, 1.1, 2.2, 3.3]
 [[7, NULL], [9, 10], [1, 2], [3, 4]] [10.1, NULL, 12.2, 1.1, 2.2, 3.3]
 [[1, 2], [3, 4]] [13.3, 14.4, 15.5, 1.1, 2.2, 3.3]
+[[1, 2], [3, 4]] [1.1, 2.2, 3.3]
 [[11, 12], [13, 14], [1, 2], [3, 4]] [1.1, 2.2, 3.3]
 [[15, 16], [NULL, 18], [1, 2], [3, 4]] [16.6, 17.7, 18.8, 1.1, 2.2, 3.3]
 
@@ -3299,6 +3316,7 @@ select array_concat(column3, make_array('.', '.', '.')) from arrays;
 [d, NULL, l, o, r, ., ., .]
 [s, i, t, ., ., .]
 [a, m, e, t, ., ., .]
+[a, m, e, t, ., ., .]
 [,, ., ., .]
 [., ., .]
 
@@ -4704,6 +4722,7 @@ NULL 0
 #NULL 0
 
 # cardinality with columns
+# FIXME cardinality on empty array should be NULL or zero?
 query III
 select cardinality(column1), cardinality(column2), cardinality(column3) from arrays;
 ----
@@ -4712,6 +4731,7 @@ select cardinality(column1), cardinality(column2), cardinality(column3) from arr
 4 3 5
 4 3 3
 NULL 3 4
+NULL NULL 4
 4 NULL 1
 4 3 NULL
 
@@ -4723,6 +4743,7 @@ select cardinality(column1), cardinality(column2), cardinality(column3) from lar
 4 3 5
 4 3 3
 NULL 3 4
+NULL NULL 4
 4 NULL 1
 4 3 NULL
 
@@ -5406,6 +5427,7 @@ select array_dims(column1), array_dims(column2), array_dims(column3) from arrays
 [2, 2] [3] [5]
 [2, 2] [3] [3]
 NULL [3] [4]
+NULL NULL [4]
 [2, 2] NULL [1]
 [2, 2] [3] NULL
 
@@ -5417,6 +5439,7 @@ select array_dims(column1), array_dims(column2), array_dims(column3) from large_
 [2, 2] [3] [5]
 [2, 2] [3] [3]
 NULL [3] [4]
+NULL NULL [4]
 [2, 2] NULL [1]
 [2, 2] [3] NULL
 
@@ -5575,6 +5598,7 @@ select array_ndims(column1), array_ndims(column2), array_ndims(column3) from arr
 2 1 1
 2 1 1
 NULL 1 1
+NULL 1 1
 2 NULL 1
 2 1 NULL
 
@@ -5586,6 +5610,7 @@ select array_ndims(column1), array_ndims(column2), array_ndims(column3) from lar
 2 1 1
 2 1 1
 NULL 1 1
+NULL 1 1
 2 NULL 1
 2 1 NULL
 
@@ -5907,6 +5932,7 @@ true false true false
 true false false true
 false true false false
 NULL NULL false false
+NULL NULL false false
 false false NULL false
 false false false NULL
 
@@ -5922,6 +5948,7 @@ true false true false
 true false false true
 false true false false
 NULL NULL false false
+NULL NULL false false
 false false NULL false
 false false false NULL
 
@@ -7442,27 +7469,29 @@ false
 #NULL
 
 # empty scalar function #5
-query B
-select empty(column1) from arrays;
+query BB
+select empty(column1), empty(column2) from arrays;
 ----
-false
-false
-false
-false
-NULL
-false
-false
+false false
+false false
+false false
+false false
+NULL false
+NULL true
+false NULL
+false false
 
-query B
-select empty(arrow_cast(column1, 'LargeList(List(Int64))')) from arrays;
+query BB
+select empty(arrow_cast(column1, 'LargeList(List(Int64))')), empty(arrow_cast(column2, 'LargeList(Int64)')) from arrays;
 ----
-false
-false
-false
-false
-NULL
-false
-false
+false false
+false false
+false false
+false false
+NULL false
+NULL true
+false NULL
+false false
 
 query B
 select empty(column1) from fixed_size_arrays;
