diff --git a/src/sql/engine/user_defined_function/ob_pl_user_defined_agg_function.cpp b/src/sql/engine/user_defined_function/ob_pl_user_defined_agg_function.cpp index 622fd928b4..e9d2744ef3 100644 --- a/src/sql/engine/user_defined_function/ob_pl_user_defined_agg_function.cpp +++ b/src/sql/engine/user_defined_function/ob_pl_user_defined_agg_function.cpp @@ -155,8 +155,9 @@ int ObPlAggUdfFunction::call_pl_engine_exectue_udf(ParamStore& udf_params, K(ret), K(udf_params.count()), K(routine_info->get_param_count())); } else if (OB_FAIL(pl_engine->execute(*exec_ctx_, exec_ctx_->get_allocator(), - -1, - routine_info->get_routine_id(), + share::schema::ObUDTObjectType::mask_object_id(routine_info->get_package_id()), + OB_INVALID_ID != routine_info->get_package_id() ? routine_info->get_subprogram_id() + : routine_info->get_routine_id(), empty_subprogram_path, udf_params, empty_nocopy_params,