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; } } }