From 01c4b6ec1979e7409b3bc65b91ec40e0a08693e4 Mon Sep 17 00:00:00 2001 From: dongning12 Date: Sat, 10 Dec 2022 14:53:55 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=85=B1=E4=BA=AB=E5=AD=98=E5=82=A8]=20backen?= =?UTF-8?q?d=20choose=20to=20terminated?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/gausskernel/ddes/adapter/ss_transaction.cpp | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/gausskernel/ddes/adapter/ss_transaction.cpp b/src/gausskernel/ddes/adapter/ss_transaction.cpp index a7551e94b..e338f477f 100644 --- a/src/gausskernel/ddes/adapter/ss_transaction.cpp +++ b/src/gausskernel/ddes/adapter/ss_transaction.cpp @@ -133,6 +133,9 @@ CommitSeqNo SSTransactionIdGetCommitSeqNo(TransactionId transactionId, bool isCo ereport(DEBUG1, (errmsg("SS get txn info success, snapshot is NULL"))); } } else { + if (SS_IN_FAILOVER && (t_thrd.role == WORKER || t_thrd.role == THREADPOOL_WORKER)) { + ereport(FATAL, (errmsg("SS get CSN by TransactionId failed during failover, xid=%lu", transactionId))); + } pg_usleep(USECS_PER_SEC); continue; }