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

fix exec ctx in direct load client task

Browse Source
This commit is contained in:
suz-yang 2024-12-27 03:46:00 +00:00 committed by ob-robot
parent bfc10616a3
commit d928821da3
2 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/observer/table_load/ob_table_load_client_task.cpp
View File

@ -595,8 +595,15 @@ int ObTableLoadClientTask::init_exec_ctx()
exec_ctx_.set_sql_ctx(&sql_ctx_);
exec_ctx_.set_physical_plan_ctx(&plan_ctx_);
exec_ctx_.set_my_session(session_info_);
client_exec_ctx_.exec_ctx_ = &exec_ctx_;
client_exec_ctx_.init_heart_beat(param_.get_heartbeat_timeout_us());
if (OB_FAIL(session_info_->set_cur_phy_plan(&plan_))) {
LOG_WARN("fail to set cur phy plan", KR(ret));
} else if (FALSE_IT(exec_ctx_.reference_my_plan(&plan_))) {
} else if (OB_FAIL(exec_ctx_.init_phy_op(1))) {
LOG_WARN("fail to init phy op", KR(ret));
} else {
client_exec_ctx_.exec_ctx_ = &exec_ctx_;
client_exec_ctx_.init_heart_beat(param_.get_heartbeat_timeout_us());
}
}
return ret;
}

1
src/observer/table_load/ob_table_load_client_task.h
View File

@ -177,6 +177,7 @@ private:
sql::ObFreeSessionCtx free_session_ctx_;
sql::ObSqlCtx sql_ctx_;
sql::ObPhysicalPlanCtx plan_ctx_;
ObPhysicalPlan plan_;
ObExecContext exec_ctx_;
ObTableLoadClientExecCtx client_exec_ctx_;
ObITableLoadTaskScheduler *task_scheduler_;