fix(stream): check return value.

2024-12-12 09:35:35 +08:00 · 2024-12-12 09:35:35 +08:00 · aa187f1ee3
parent aa12038fc4
commit aa187f1ee3
1 changed files with 2 additions and 1 deletions
--- a/source/libs/stream/src/streamDispatch.c
+++ b/source/libs/stream/src/streamDispatch.c
@ -1747,7 +1747,8 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
  }

  if (addFailure) {  // add failure downstream node id, and start the nodeEp update procedure
-    streamTaskAddIntoNodeUpdateList(pTask, pRsp->downstreamNodeId);
+    // ignore the return error and continue
+    int32_t unused = streamTaskAddIntoNodeUpdateList(pTask, pRsp->downstreamNodeId);
  }

  // all msg rsp already, continue