From 2724fb32a8dc039e533a2c37d8c95246c60be4ba Mon Sep 17 00:00:00 2001 From: obdev Date: Fri, 21 Jun 2024 09:16:23 +0000 Subject: [PATCH] the resource management module has not been allocated, return OB_EAGAIN --- .../table_load/resource/ob_table_load_resource_service.cpp | 6 +++--- test/.obcdc_conf | 7 +++++++ 2 files changed, 10 insertions(+), 3 deletions(-) create mode 100644 test/.obcdc_conf diff --git a/src/observer/table_load/resource/ob_table_load_resource_service.cpp b/src/observer/table_load/resource/ob_table_load_resource_service.cpp index 3ec526cd9..7544ff298 100644 --- a/src/observer/table_load/resource/ob_table_load_resource_service.cpp +++ b/src/observer/table_load/resource/ob_table_load_resource_service.cpp @@ -273,7 +273,7 @@ int ObTableLoadResourceService::local_apply_resource(ObDirectLoadResourceApplyAr ret = OB_ERR_SYS; LOG_WARN("null table load resource service", KR(ret)); } else if(OB_ISNULL(service->resource_manager_)) { - ret = OB_ERR_SYS; + ret = OB_EAGAIN; LOG_WARN("resource_manager_ is null", KR(ret)); } else { ret = service->resource_manager_->apply_resource(arg, res); @@ -290,7 +290,7 @@ int ObTableLoadResourceService::local_release_resource(ObDirectLoadResourceRelea ret = OB_ERR_SYS; LOG_WARN("null table load resource service", KR(ret)); } else if(OB_ISNULL(service->resource_manager_)) { - ret = OB_ERR_SYS; + ret = OB_EAGAIN; LOG_WARN("resource_manager_ is null", KR(ret)); } else { ret = service->resource_manager_->release_resource(arg); @@ -307,7 +307,7 @@ int ObTableLoadResourceService::local_update_resource(ObDirectLoadResourceUpdate ret = OB_ERR_SYS; LOG_WARN("null table load resource service", KR(ret)); } else if(OB_ISNULL(service->resource_manager_)) { - ret = OB_ERR_SYS; + ret = OB_EAGAIN; LOG_WARN("resource_manager_ is null", KR(ret)); } else { ret = service->resource_manager_->update_resource(arg); diff --git a/test/.obcdc_conf b/test/.obcdc_conf new file mode 100644 index 000000000..9fab9a2fd --- /dev/null +++ b/test/.obcdc_conf @@ -0,0 +1,7 @@ +build_target=obcdc,obcdc_tailf +code_path=src/logservice/libobcdc/ +output_path=src/logservice/libobcdc/ +so_name=libobcdc.so +so_name_V=libobcdc.so.4 +so_name_v=libobcdc.so.4.3.2.0 +tailf_name=obcdc_tailf