Fix 4015 error.

This commit is contained in:
obdev
2023-02-07 17:13:31 +08:00
committed by ob-robot
parent dde384c169
commit cc9cadb3ad

View File

@ -544,7 +544,10 @@ int DASOpResultIter::get_next_rows(int64_t &count, int64_t capacity)
//remote task will change datum ptr, need to mark this flag
//in order to let the next local task reset datum ptr before get_next_rows
wild_datum_info_->exprs_ = &scan_op->get_result_outputs();
wild_datum_info_->max_output_rows_ = max(count, wild_datum_info_->max_output_rows_);
//Now in the group scan op, we implement jump read.
//We may touch more rows than count return.
//So we need to reset all of ptr in the output expr datum.
wild_datum_info_->max_output_rows_ = max(capacity, wild_datum_info_->max_output_rows_);
}
}
} else {