diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c
index fb2eb29c0b74d78d82c7b016879a0b7caa946827..3210a4bce09920baa7165faf44ad36e04b62c49e 100644
--- a/source/libs/stream/src/streamRecover.c
+++ b/source/libs/stream/src/streamRecover.c
@@ -202,7 +202,13 @@ int32_t streamRecheckDownstream(SStreamTask* pTask, const SStreamTaskCheckRsp* p
 
 int32_t streamTaskCheckStatus(SStreamTask* pTask, int32_t upstreamTaskId, int32_t vgId, int64_t stage) {
   SStreamChildEpInfo* pInfo = streamTaskGetUpstreamTaskEpInfo(pTask, upstreamTaskId);
-  ASSERT(pInfo != NULL && pInfo->stage <= stage);
+  ASSERT(pInfo != NULL);
+
+  if (stage == -1) {
+    qDebug("s-task:%s receive msg from upstream task:0x%x, invalid stageId, not ready", pTask->id.idStr, upstreamTaskId,
+           stage);
+    return 0;
+  }
 
   if (pInfo->stage == -1) {
     pInfo->stage = stage;