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

[BUGFIX] fix join filter core due to overwriting error code

Browse Source
This commit is contained in:
obdev 2024-09-20 05:59:08 +00:00 committed by ob-robot
parent 5f10b7f3bb
commit d51c675cd7
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/sql/engine/join/ob_join_filter_op.cpp
View File

@ -1344,9 +1344,10 @@ int ObJoinFilterOp::init_material_parameters()
OB_NEWx(ObJoinFilterPartitionSplitter, &ctx_.get_allocator()))) {
ret = OB_ALLOCATE_MEMORY_FAILED;
LOG_WARN("failed to allocate memory for ObJoinFilterPartitionSplitter");
} else if (partition_splitter_->init(tenant_id, mem_context_, eval_ctx_, &sql_mem_processor_,
MY_SPEC.full_hash_join_keys_, MY_SPEC.output_,
extra_hash_count, max_batch_size, compress_type)) {
} else if (OB_FAIL(partition_splitter_->init(tenant_id, mem_context_, eval_ctx_,
&sql_mem_processor_, MY_SPEC.full_hash_join_keys_,
MY_SPEC.output_, extra_hash_count, max_batch_size,
compress_type))) {
LOG_WARN("failed to init partition splitter");
} else if (OB_FAIL(partition_splitter_->prepare_join_partitions(
&io_event_observer_, worker_row_count, worker_memory_size))) {