From acfcfdc8b612c2e042f4e9c1c0f3ba5daff8c681 Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Fri, 8 Dec 2023 15:51:01 +0800 Subject: [PATCH] opti:build task logic in stream --- source/dnode/mnode/impl/src/mndScheduler.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndScheduler.c b/source/dnode/mnode/impl/src/mndScheduler.c index 80bf084f1a..fef18574e6 100644 --- a/source/dnode/mnode/impl/src/mndScheduler.c +++ b/source/dnode/mnode/impl/src/mndScheduler.c @@ -559,7 +559,7 @@ static int32_t doScheduleStream(SStreamObj* pStream, SMnode* pMnode, SQueryPlan* pStream->tasks = taosArrayInit(numOfPlanLevel + 1, POINTER_BYTES); pStream->pHTasksList = taosArrayInit(numOfPlanLevel + 1, POINTER_BYTES); - if (numOfPlanLevel == 2 || externalTargetDB || multiTarget || pStream->fixedSinkVgId) { + if (numOfPlanLevel > 1 || externalTargetDB || multiTarget || pStream->fixedSinkVgId) { // add extra sink hasExtraSink = true; int32_t code = addSinkTask(pMnode, pStream, pEpset); @@ -596,7 +596,7 @@ static int32_t doScheduleStream(SStreamObj* pStream, SMnode* pMnode, SQueryPlan* bindAggSink(pStream, pMnode, pStream->pHTasksList); } - plan = getScanSubPlan(pPlan, 1); + plan = getScanSubPlan(pPlan, numOfPlanLevel - 1); if(plan == NULL){ return terrno; }