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

refactor: do some internal refactor.

This commit is contained in:
Haojun Liao 2023-10-21 16:38:46 +08:00
parent 4826b34a2b
commit 825195b351
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
source/dnode/mnode/impl/src/mndStream.c
View File

@ -2632,9 +2632,12 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) {
// current checkpoint is failed, rollback from the checkpoint trans
// kill the checkpoint trans and then set all tasks status to be normal
if (checkpointFailed && activeCheckpointId != 0) {
ASSERT(execInfo.activeCheckpoint == activeCheckpointId);
// if the execInfo.activeCheckpoint == 0, the checkpoint is restoring from wal
if (execInfo.activeCheckpoint != 0) {
ASSERT(execInfo.activeCheckpoint == activeCheckpointId);
}
mInfo("checkpointId:%" PRId64 " failed, issue task-reset trans to reset all tasks status", activeCheckpointId);
// execInfo.activeCheckpoint = activeCheckpointId;
mndResetFromCheckpoint(pMnode);
// } else {
// mDebug("checkpoint:%"PRId64" reset has issued already, ignore it", activeCheckpointId);