From a927ca8bc43577c61e1fa0fb50f3d9c7678ed467 Mon Sep 17 00:00:00 2001 From: Shengliang Guan Date: Sat, 25 Dec 2021 16:11:57 +0800 Subject: [PATCH] minor changes --- source/dnode/mnode/impl/src/mndTrans.c | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndTrans.c b/source/dnode/mnode/impl/src/mndTrans.c index 1697936a26..0b714c34ae 100644 --- a/source/dnode/mnode/impl/src/mndTrans.c +++ b/source/dnode/mnode/impl/src/mndTrans.c @@ -660,8 +660,9 @@ static int32_t mndTransExecuteActions(SMnode *pMnode, STrans *pTrans, SArray *pA for (int32_t action = 0; action < numOfActions; ++action) { STransAction *pAction = taosArrayGet(pArray, action); if (pAction == NULL) continue; - if (pAction->msgSent && !pAction->msgReceived) continue; - if (pAction->msgSent && pAction->msgReceived && pAction->errCode == 0) continue; + // if (pAction->msgSent && !pAction->msgReceived) continue; + // if (pAction->msgSent && pAction->msgReceived && pAction->errCode == 0) continue; + if (pAction->msgSent) continue; int64_t signature = pTrans->id; signature = (signature << 32);