From d51c675cd7af7549c9fb6c4e43d90ba1534beaac Mon Sep 17 00:00:00 2001 From: obdev Date: Fri, 20 Sep 2024 05:59:08 +0000 Subject: [PATCH] [BUGFIX] fix join filter core due to overwriting error code --- src/sql/engine/join/ob_join_filter_op.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/sql/engine/join/ob_join_filter_op.cpp b/src/sql/engine/join/ob_join_filter_op.cpp index ff41c9b34..683dfe928 100644 --- a/src/sql/engine/join/ob_join_filter_op.cpp +++ b/src/sql/engine/join/ob_join_filter_op.cpp @@ -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))) {