fix(stream): add return.

2023-11-15 16:53:51 +08:00 · 2023-11-15 16:53:51 +08:00 · 974d0bbb48
parent 115246c877
commit 974d0bbb48
1 changed files with 1 additions and 0 deletions
--- 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