From a882c639bebb0fc767979adba74edede16ea13a4 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sun, 22 Oct 2023 16:16:59 +0800 Subject: [PATCH] fix(stream): remove invalid assert. --- source/dnode/mnode/impl/src/mndStream.c | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 28c22d5248..194c1021f6 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -2633,15 +2633,8 @@ int32_t mndProcessStreamHb(SRpcMsg *pReq) { // kill the checkpoint trans and then set all tasks status to be normal if (checkpointFailed && activeCheckpointId != 0) { // 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); + mInfo("checkpointId:%" PRId64 " failed, issue task-reset trans to reset all tasks status", execInfo.activeCheckpoint); mndResetFromCheckpoint(pMnode); - // } else { - // mDebug("checkpoint:%"PRId64" reset has issued already, ignore it", activeCheckpointId); - // } } taosThreadMutexUnlock(&execInfo.lock);