From 974d0bbb48ee19d38391bf824b9b308cda2f9cde Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 15 Nov 2023 16:53:51 +0800 Subject: [PATCH] fix(stream): add return. --- source/dnode/mnode/impl/src/mndStream.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 549b14cf0f..a870f9d000 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1211,6 +1211,7 @@ static int32_t mndProcessStreamDoCheckpoint(SRpcMsg *pReq) { bool updated = taskNodeIsUpdated(pMnode); if (updated) { mWarn("checkpoint ignore, stream task nodes update detected"); + return -1; } { // check if all tasks are in TASK_STATUS__READY status