commit
d3157a2d32
|
@ -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);
|
||||
|
|
Loading…
Reference in New Issue