From 41aa175099d37e795f99f2acee5b00a40c23479e 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 d3f96d46d2..7ada3c33fd 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -1231,6 +1231,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