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

[CP] [to #46597683] fix session memory expansion by pkg var serialize

Browse Source
This commit is contained in:
obdev
2022-12-27 10:11:42 +00:00
committed by ob-robot
parent c2bf552dba
commit 509c446234
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/sql/session/ob_sql_session_info.cpp
View File

@ -1826,13 +1826,14 @@ bool ObSQLSessionInfo::get_changed_package_state_num() const
int ObSQLSessionInfo::add_changed_package_info(ObExecContext &exec_ctx) int ObSQLSessionInfo::add_changed_package_info(ObExecContext &exec_ctx)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObPLExecCtx pl_ctx(&get_allocator(), &exec_ctx, NULL, NULL, NULL, NULL); ObPLExecCtx pl_ctx(NULL, &exec_ctx, NULL, NULL, NULL, NULL);
ObArray<ObString> key; ObArray<ObString> key;
ObArray<ObObj> value; ObArray<ObObj> value;
if (0 != package_state_map_.size()) { if (0 != package_state_map_.size()) {
FOREACH(it, package_state_map_) { FOREACH(it, package_state_map_) {
ObPLPackageState *package_state = it->second; ObPLPackageState *package_state = it->second;
if (package_state->is_package_info_changed()) { if (package_state->is_package_info_changed()) {
pl_ctx.allocator_ = &(package_state->get_pkg_allocator());
if (OB_FAIL(package_state->convert_changed_info_to_string_kvs(pl_ctx, key, value))) { if (OB_FAIL(package_state->convert_changed_info_to_string_kvs(pl_ctx, key, value))) {
LOG_WARN("convert package state to string kv failed", LOG_WARN("convert package state to string kv failed",
K(ret), KPC(package_state)); K(ret), KPC(package_state));