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

to issue<49860566>:fix core when disconnect connection after udf execute failed

Browse Source
This commit is contained in:
hanr881
2023-05-30 08:53:24 +00:00
committed by ob-robot
parent 3803e66aac
commit fa886fed1d
1 changed files with 24 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
src/sql/engine/expr/ob_expr_udf.cpp
View File

@ -497,12 +497,12 @@ int ObExprUDF::eval_udf(const ObExpr &expr, ObEvalCtx &ctx, ObDatum &res)
CK (0 < udf_params->count()); CK (0 < udf_params->count());
OZ (ns.init_complex_obj(alloc, pl_type, udf_params->at(0), false, false)); OZ (ns.init_complex_obj(alloc, pl_type, udf_params->at(0), false, false));
} }
try { try {
int64_t package_id = info->is_udt_udf_ ? int64_t package_id = info->is_udt_udf_ ?
share::schema::ObUDTObjectType::mask_object_id(info->udf_package_id_) share::schema::ObUDTObjectType::mask_object_id(info->udf_package_id_)
: info->udf_package_id_; : info->udf_package_id_;
OZ(pl_engine->execute(ctx.exec_ctx_, if (OB_FAIL(ret)) {
} else if (OB_FAIL(pl_engine->execute(ctx.exec_ctx_,
info->is_called_in_sql_ ? allocator info->is_called_in_sql_ ? allocator
: alloc, : alloc,
package_id, package_id,
@ -515,13 +515,28 @@ int ObExprUDF::eval_udf(const ObExpr &expr, ObEvalCtx &ctx, ObDatum &res)
false, false,
true, true,
info->loc_, info->loc_,
info->is_called_in_sql_), info->is_called_in_sql_))) {
LOG_WARN("fail to execute udf", K(ret), K(info), K(package_id), K(tmp_result));
info->udf_id_, bool has_out_param = false;
info->udf_package_id_, for (int64_t i = 0; !has_out_param && i < info->params_desc_.count(); ++i) {
info->is_udt_udf_, if (info->params_desc_.at(i).is_out()) {
tmp_result, has_out_param = true;
package_id); }
}
if (has_out_param) {
int tmp = process_out_params(objs,
expr.arg_cnt_,
*udf_params,
alloc,
ctx.exec_ctx_,
info->nocopy_params_,
info->params_desc_,
info->params_type_);
if (OB_SUCCESS != tmp) {
LOG_WARN("fail to process out param", K(tmp), K(ret));
}
}
}
} catch(...) { } catch(...) {
throw; throw;
} }