Skip to content

Commit e3ec458

Browse files
committed
fix: correctly apply validity check
1 parent a754224 commit e3ec458

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/include/utils.hpp

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -325,7 +325,7 @@ inline void DistributionCallBinaryNone(DataChunk &args, ExpressionState &state,
325325
auto &result_data_children = ArrayVector::GetEntry(result);
326326
auto result_data = FlatVector::GetData<double>(result_data_children);
327327

328-
if (!dist_param1_data.validity.AllValid() || !dist_param1_data.validity.AllValid()) {
328+
if (!dist_param1_data.validity.AllValid() || !dist_param2_data.validity.AllValid()) {
329329
auto result_validity = FlatVector::Validity(result);
330330
for (idx_t i = 0; i < args.size(); i++) {
331331
auto dist_param1_index = dist_param1_data.sel->get_index(i);
@@ -371,7 +371,7 @@ inline void DistributionCallBinaryNone(DataChunk &args, ExpressionState &state,
371371
auto &result_data_children = ArrayVector::GetEntry(result);
372372
auto result_data = FlatVector::GetData<int64_t>(result_data_children);
373373

374-
if (!dist_param1_data.validity.AllValid() || !dist_param1_data.validity.AllValid()) {
374+
if (!dist_param1_data.validity.AllValid() || !dist_param2_data.validity.AllValid()) {
375375
auto result_validity = FlatVector::Validity(result);
376376
for (idx_t i = 0; i < args.size(); i++) {
377377
auto dist_param1_index = dist_param1_data.sel->get_index(i);
@@ -474,7 +474,7 @@ inline void DistributionCallUnaryNone(DataChunk &args, ExpressionState &state, V
474474
auto &result_data_children = ArrayVector::GetEntry(result);
475475
auto result_data = FlatVector::GetData<double>(result_data_children);
476476

477-
if (!dist_param1_data.validity.AllValid() || !dist_param1_data.validity.AllValid()) {
477+
if (!dist_param1_data.validity.AllValid()) {
478478
auto result_validity = FlatVector::Validity(result);
479479
for (idx_t i = 0; i < args.size(); i++) {
480480
auto dist_param1_index = dist_param1_data.sel->get_index(i);
@@ -512,7 +512,7 @@ inline void DistributionCallUnaryNone(DataChunk &args, ExpressionState &state, V
512512
auto &result_data_children = ArrayVector::GetEntry(result);
513513
auto result_data = FlatVector::GetData<int64_t>(result_data_children);
514514

515-
if (!dist_param1_data.validity.AllValid() || !dist_param1_data.validity.AllValid()) {
515+
if (!dist_param1_data.validity.AllValid()) {
516516
auto result_validity = FlatVector::Validity(result);
517517
for (idx_t i = 0; i < args.size(); i++) {
518518
auto dist_param1_index = dist_param1_data.sel->get_index(i);

0 commit comments

Comments
 (0)