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

Switch current memory context for sqc handler

Browse Source
This commit is contained in:
qianchanger 2023-03-07 05:16:14 +00:00 committed by ob-robot
parent bb6dd9d016
commit 8c423e7ff3
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/sql/engine/px/ob_px_sqc_handler.cpp
View File

@ -225,11 +225,13 @@ int ObPxSqcHandler::copy_sqc_init_arg(int64_t &pos, const char *data_buf, int64_
LOG_WARN("Sqc handler need to be inited", K(ret));
} else {
allocator = &mem_context_->get_arena_allocator();
sqc_init_args_->set_deserialize_param(*exec_ctx_, *des_phy_plan_, allocator);
if (OB_FAIL(sqc_init_args_->do_deserialize(pos, data_buf, data_len))) {
LOG_WARN("Failed to deserialize", K(ret));
WITH_CONTEXT(mem_context_) {
sqc_init_args_->set_deserialize_param(*exec_ctx_, *des_phy_plan_, allocator);
if (OB_FAIL(sqc_init_args_->do_deserialize(pos, data_buf, data_len))) {
LOG_WARN("Failed to deserialize", K(ret));
}
sqc_init_args_->sqc_handler_ = this;
}
sqc_init_args_->sqc_handler_ = this;
}
return ret;
}