enh/TD-29974-improve-trans-fix-case
This commit is contained in:
parent
344c51fcc7
commit
6f124e7b23
|
@ -2241,7 +2241,7 @@ static int32_t mndRetrieveTrans(SRpcMsg *pReq, SShowObj *pShow, SSDataBlock *pBl
|
|||
|
||||
const char *killableStr = pTrans->ableToBeKilled ? "yes" : "no";
|
||||
char killableVstr[10 + VARSTR_HEADER_SIZE] = {0};
|
||||
STR_WITH_MAXSIZE_TO_VARSTR(killableVstr, killableStr, 24);
|
||||
STR_WITH_MAXSIZE_TO_VARSTR(killableVstr, killableStr, 10 + VARSTR_HEADER_SIZE);
|
||||
pColInfo = taosArrayGet(pBlock->pDataBlock, cols++);
|
||||
RETRIEVE_CHECK_GOTO(colDataSetVal(pColInfo, numOfRows, (const char *)killableVstr, false), pTrans, &lino, _OVER);
|
||||
|
||||
|
|
|
@ -81,9 +81,14 @@ class TDTestCase:
|
|||
rows = tdSql.query(f"select * from information_schema.ins_transaction_details", queryTimes=1)
|
||||
|
||||
if rows != 296:
|
||||
tdLog.exit(f"restore transaction detial error, rows={rows}")
|
||||
tdLog.exit(f"show transaction detial error, rows={rows}")
|
||||
return False
|
||||
|
||||
dnode.starttaosd()
|
||||
|
||||
t1.join()
|
||||
t2.join()
|
||||
|
||||
def createDbThread(self, sql, newTdSql):
|
||||
tdLog.info("CREATE DATABASE db2 vgroups 40 replica 3;")
|
||||
newTdSql.execute('CREATE DATABASE db2 vgroups 40 replica 3;', queryTimes=1)
|
||||
|
|
Loading…
Reference in New Issue