From 7d617a7cdeb2c7c733b1d130e7fea83032c58642 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 19 Feb 2025 00:39:01 +0800 Subject: [PATCH] fix(stream): fix the invalid start task condition 1. Get the basic checkpointId, and wait for 10 s, it's allowed to go. 2. All tasks have the same checkpointId, go immedidately. --- source/dnode/mnode/impl/src/mndStream.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/mnode/impl/src/mndStream.c b/source/dnode/mnode/impl/src/mndStream.c index 247024b283..11fd2d4f65 100644 --- a/source/dnode/mnode/impl/src/mndStream.c +++ b/source/dnode/mnode/impl/src/mndStream.c @@ -2686,7 +2686,7 @@ int32_t mndProcessConsensusInTmr(SRpcMsg *pMsg) { break; } - if (((now - pe->ts) >= 10 * 1000) && allSame) { + if (((now - pe->ts) >= 10 * 1000) || allSame) { mDebug("s-task:0x%x sendTs:%" PRId64 " wait %.2fs and all tasks have same checkpointId", pe->req.taskId, pe->req.startTs, (now - pe->ts) / 1000.0); if (chkId > pe->req.checkpointId) {