hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix runtime in filter core when allocate memory failed

Browse Source
This commit is contained in:
obdev
2024-03-28 08:50:41 +00:00
committed by ob-robot
parent f03ab8c186
commit 8804a2d9c7
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/engine/px/p2p_datahub/ob_runtime_filter_vec_msg.cpp
View File

@ -981,9 +981,8 @@ int ObRFInFilterVecMsg::ObRFInFilterRowStore::create_and_add_row(
ObIVector *vec = expr->get_vector(ctx); ObIVector *vec = expr->get_vector(ctx);
OZ(vec->to_row(row_meta, row, batch_idx, i)); OZ(vec->to_row(row_meta, row, batch_idx, i));
} }
uint64_t &extra_payload = row->extra_payload<uint64_t>(row_meta);
extra_payload = hash_val;
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (FALSE_IT(row->extra_payload<uint64_t>(row_meta) = hash_val)) {
} else if (OB_FAIL(serial_rows_.push_back(row))) { } else if (OB_FAIL(serial_rows_.push_back(row))) {
LOG_WARN("failed to push back row"); LOG_WARN("failed to push back row");
} else if (OB_FAIL(row_sizes_.push_back(row_size))) { } else if (OB_FAIL(row_sizes_.push_back(row_size))) {