From 57b6f5b268767b20223762d0c2fee9f60c86a4db Mon Sep 17 00:00:00 2001 From: scmysxb Date: Fri, 16 Aug 2024 15:43:01 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9query=5Fpage=5Fdistribution?= =?UTF-8?q?=5Finfo=E7=9A=84=E9=94=99=E8=AF=AF=E6=8F=90=E7=A4=BA=E4=BF=A1?= =?UTF-8?q?=E6=81=AF=E7=AD=89=E7=BA=A7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/common/backend/utils/adt/pgstatfuncs.cpp | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/common/backend/utils/adt/pgstatfuncs.cpp b/src/common/backend/utils/adt/pgstatfuncs.cpp index 0c1809fc7..48df7597b 100644 --- a/src/common/backend/utils/adt/pgstatfuncs.cpp +++ b/src/common/backend/utils/adt/pgstatfuncs.cpp @@ -15288,9 +15288,6 @@ Datum query_page_distribution_info_internal(text* relname, ForkNumber fork, Bloc int is_found = 0; int ret = get_drc_info(&is_found, drc_info); - if (ret != DMS_SUCCESS) { - ereport(ERROR, (errmsg("[SS] some errors occurred while querying DRC!"))); - } if (!is_found) { ereport(INFO, (errmsg("[SS] could not find a DRC entry in DRC for page (%u/%u/%u/%d/%d %d-%u)!", rnode.spcNode, rnode.dbNode, rnode.relNode, rnode.bucketNode, rnode.opt, fork, blockno))); @@ -15302,6 +15299,10 @@ Datum query_page_distribution_info_internal(text* relname, ForkNumber fork, Bloc iterate->iterate_idx = 0; count = (drc_info->claimed_owner == masterId) ? count : count + 1; + if (ret != DMS_SUCCESS) { + ereport(WARNING, (errmsg("[SS] some errors occurred while querying DRC!"))); + iterate->iterate_idx = DMS_MAX_INSTANCES; + } funcctx->user_fctx = (void*)iterate; funcctx->tuple_desc = create_query_page_distribution_info_tupdesc(); funcctx->max_calls = (!is_found) ? 0 : (count + 1);