fix(stream): ignore the invalid_vgroup_id error for checkpoint_trans.

This commit is contained in:
Haojun Liao 2024-07-11 15:12:05 +08:00
parent 15573efbbc
commit 4e684c400d
1 changed files with 2 additions and 2 deletions

View File

@ -966,8 +966,8 @@ static int32_t doSetCheckpointAction(SMnode *pMnode, STrans *pTrans, SStreamTask
return -1;
}
code =
setTransAction(pTrans, buf, tlen, TDMT_VND_STREAM_CHECK_POINT_SOURCE, &epset, TSDB_CODE_SYN_PROPOSE_NOT_READY, 0);
code = setTransAction(pTrans, buf, tlen, TDMT_VND_STREAM_CHECK_POINT_SOURCE, &epset, TSDB_CODE_SYN_PROPOSE_NOT_READY,
TSDB_CODE_VND_INVALID_VGROUP_ID);
if (code != 0) {
taosMemoryFree(buf);
}