GetWorkerIds 函数在进行线程id检查的时候缺少本应有的报错信息
This commit is contained in:
@ -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);
|
||||
|
||||
@ -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;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user