From 59c69786373ca0dbf915c40607e97d375dccda83 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=AD=90=E7=BB=B4?= Date: Sat, 11 May 2024 14:05:41 +0800 Subject: [PATCH] =?UTF-8?q?GetWorkerIds=20=E5=87=BD=E6=95=B0=E5=9C=A8?= =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E7=BA=BF=E7=A8=8Bid=E6=A3=80=E6=9F=A5?= =?UTF-8?q?=E7=9A=84=E6=97=B6=E5=80=99=E7=BC=BA=E5=B0=91=E6=9C=AC=E5=BA=94?= =?UTF-8?q?=E6=9C=89=E7=9A=84=E6=8A=A5=E9=94=99=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- contrib/gauss_connector/gc_fdw.cpp | 2 +- .../storage/access/transam/parallel_recovery/dispatcher.cpp | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/contrib/gauss_connector/gc_fdw.cpp b/contrib/gauss_connector/gc_fdw.cpp index 72f8aaf4f..e04abdc25 100644 --- a/contrib/gauss_connector/gc_fdw.cpp +++ b/contrib/gauss_connector/gc_fdw.cpp @@ -1720,7 +1720,7 @@ void pgfdw_fetch_remote_version(PGconn* conn) result_count = atoi(PQgetvalue(res, 0, 0)); if (result_count <= 0) { - ereport(ERROR, (errcode(ERRCODE_NO_DATA_FOUND), errmsg("gc_fdw: the remote vesion is not match."))); + ereport(ERROR, (errcode(ERRCODE_NO_DATA_FOUND), errmsg("gc_fdw: the remote version is not match."))); } PQclear(res); diff --git a/src/gausskernel/storage/access/transam/parallel_recovery/dispatcher.cpp b/src/gausskernel/storage/access/transam/parallel_recovery/dispatcher.cpp index 3aaa52a14..be9440e68 100755 --- a/src/gausskernel/storage/access/transam/parallel_recovery/dispatcher.cpp +++ b/src/gausskernel/storage/access/transam/parallel_recovery/dispatcher.cpp @@ -1453,6 +1453,10 @@ static void GetWorkerIds(XLogReaderState *record, uint32 designatedWorker, bool AddWorkerToSet(designatedWorker); } else { /* output error info */ + ereport(PANIC, (errmodule(MOD_REDO), errcode(ERRCODE_LOG), + errmsg("[REDO_LOG_TRACE]AddWorkerToSet:input work id error, id:%u, work num %u", id, + g_dispatcher->pageWorkerCount))); + return; } } }