From 13640f5f5327c0e84084d0ee1761b0354aacdd67 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 15 Aug 2023 20:46:06 +0800 Subject: [PATCH] other --- source/libs/stream/src/streamRecover.c | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/source/libs/stream/src/streamRecover.c b/source/libs/stream/src/streamRecover.c index fb2eb29c0b..3210a4bce0 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;