From d05fccca47ee8dad522a8e97ad3a2ffaa0d9a5a6 Mon Sep 17 00:00:00 2001 From: Xiaoyu Wang Date: Mon, 7 Mar 2022 22:22:03 -0500 Subject: [PATCH] TD-13747 merge 3.0 --- source/dnode/mnode/impl/src/mndScheduler.c | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/source/dnode/mnode/impl/src/mndScheduler.c b/source/dnode/mnode/impl/src/mndScheduler.c index 5308c0c0f6..02eb5c2f24 100644 --- a/source/dnode/mnode/impl/src/mndScheduler.c +++ b/source/dnode/mnode/impl/src/mndScheduler.c @@ -32,24 +32,24 @@ int32_t mndSchedInitSubEp(SMnode* pMnode, const SMqTopicObj* pTopic, SMqSubscribeObj* pSub) { SSdb* pSdb = pMnode->pSdb; SVgObj* pVgroup = NULL; - SQueryDag* pDag = qStringToDag(pTopic->physicalPlan); + SQueryPlan* pPlan = qStringToQueryPlan(pTopic->physicalPlan); SArray* pAray = NULL; SArray* unassignedVg = pSub->unassignedVg; ASSERT(pSub->vgNum == 0); - int32_t levelNum = taosArrayGetSize(pDag->pSubplans); + int32_t levelNum = LIST_LENGTH(pPlan->pSubplans); if (levelNum != 1) { return -1; } - SArray* inner = taosArrayGet(pDag->pSubplans, 0); + SNodeListNode* inner = nodesListGetNode(pPlan->pSubplans, 0); - int32_t opNum = taosArrayGetSize(inner); + int32_t opNum = LIST_LENGTH(inner->pNodeList); if (opNum != 1) { return -1; } - SSubplan* plan = taosArrayGetP(inner, 0); + SSubplan* plan = nodesListGetNode(inner->pNodeList, 0); void* pIter = NULL; while (1) {