Update cpp/src/arrow/compute/kernels/aggregate_basic_internal.h

Co-authored-by: Antoine Pitrou <pitrou@free.fr>
R-JunmingChen · Oct 19, 2023 · be9238e · be9238e
1 parent af93cbf
commit be9238e
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cpp/src/arrow/compute/kernels/aggregate_basic_internal.h b/cpp/src/arrow/compute/kernels/aggregate_basic_internal.h
@@ -941,7 +941,9 @@ struct DictionaryMinMaxImpl : public ScalarAggregator {
     }
     this->has_nulls |= compacted_dict_arr.null_count() > 0;
     this->count += compacted_dict_arr.length() - compacted_dict_arr.null_count();
-
+    if (this->has_nulls && !options.skip_nulls) {
+      return Status::OK();
+    }
     std::shared_ptr<Scalar> dict_min;
     std::shared_ptr<Scalar> dict_max;
     if (compacted_dict_arr.length() - compacted_dict_arr.null_count() == 1) {