xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix(stream):remove assert.

This commit is contained in:
Haojun Liao 2024-09-06 16:06:30 +08:00
parent 752ef0cf1d
commit 9e33244209
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/mnode/impl/src/mndStreamUtil.c
View File

@ -1893,7 +1893,7 @@ void streamTransRandomErrorGen(STransAction *pAction, STrans *pTrans, int64_t si
mError( mError(
"***sleep 5s and core dump, following tasks will not recv update-checkpoint info, so the checkpoint will " "***sleep 5s and core dump, following tasks will not recv update-checkpoint info, so the checkpoint will "
"rollback***"); "rollback***");
ASSERT(0); exit(-1);
} else if (pAction->msgType == TDMT_STREAM_CONSEN_CHKPT) { // pAction->msgType == TDMT_STREAM_CONSEN_CHKPT } else if (pAction->msgType == TDMT_STREAM_CONSEN_CHKPT) { // pAction->msgType == TDMT_STREAM_CONSEN_CHKPT
mError( mError(
"***sleep 5s and core dump, following tasks will not recv consen-checkpoint info, so the tasks will " "***sleep 5s and core dump, following tasks will not recv consen-checkpoint info, so the tasks will "
@ -1902,7 +1902,7 @@ void streamTransRandomErrorGen(STransAction *pAction, STrans *pTrans, int64_t si
mError( mError(
"***sleep 5s and core dump, following tasks will not recv checkpoint-source info, so the tasks will " "***sleep 5s and core dump, following tasks will not recv checkpoint-source info, so the tasks will "
"started after restart***"); "started after restart***");
ASSERT(0); exit(-1);
} }
} else if (choseItem == 1) { } else if (choseItem == 1) {
// 2. repeat send update chkpt msg // 2. repeat send update chkpt msg