This commit is contained in:
yupeng 2020-08-13 15:19:23 +08:00
parent b80dc6a3a3
commit 497fd660ee
1 changed files with 2 additions and 0 deletions

View File

@ -155,6 +155,7 @@ static void check_snapshot_thd_exit()
char* redis_group = PgxcGroupGetInRedistributionGroup();
if (redis_group != NULL) {
need_exit = true;
u_sess->attr.attr_common.ExitOnAnyError = true;
}
CommitTransactionCommand();
@ -1451,6 +1452,7 @@ void SnapshotNameSpace::SubSnapshotMain(void)
TablesList tablesList;
const int SLEEP_GAP_AFTER_ERROR = 1;
InitSnapshot(tablesList);
u_sess->attr.attr_common.ExitOnAnyError = false;
while (!t_thrd.perf_snap_cxt.need_exit &&
(PgxcIsCentralCoordinator(g_instance.attr.attr_common.PGXCNodeName) || IS_SINGLE_NODE) &&