database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

!6444 回合6065

Browse Source 
Merge pull request !6444 from Carl/che
This commit is contained in:
opengauss_bot
2024-09-24 13:02:18 +00:00
committed by Gitee
parent 9c06a4e035 57b6f5b268
commit 58fa9e7a9c
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/common/backend/utils/adt/pgstatfuncs.cpp
View File

@ -15313,9 +15313,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)));
@ -15327,6 +15324,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);