reorganize physical plan code
This commit is contained in:
parent
f893b65622
commit
1a77904e7e
|
@ -669,7 +669,7 @@ static int32_t createIntervalPhysiNode(SPhysiPlanContext* pCxt, SNodeList* pChil
|
||||||
pInterval->slidingUnit = pWindowLogicNode->slidingUnit;
|
pInterval->slidingUnit = pWindowLogicNode->slidingUnit;
|
||||||
|
|
||||||
pInterval->pFill = nodesCloneNode(pWindowLogicNode->pFill);
|
pInterval->pFill = nodesCloneNode(pWindowLogicNode->pFill);
|
||||||
if (NULL == pInterval->pFill) {
|
if (NULL != pWindowLogicNode->pFill && NULL == pInterval->pFill) {
|
||||||
nodesDestroyNode(pInterval);
|
nodesDestroyNode(pInterval);
|
||||||
return TSDB_CODE_OUT_OF_MEMORY;
|
return TSDB_CODE_OUT_OF_MEMORY;
|
||||||
}
|
}
|
||||||
|
|
|
@ -39,6 +39,7 @@ int32_t qCreateQueryPlan(SPlanContext* pCxt, SQueryPlan** pPlan, SArray* pExecNo
|
||||||
nodesDestroyNode(pLogicNode);
|
nodesDestroyNode(pLogicNode);
|
||||||
nodesDestroyNode(pLogicSubplan);
|
nodesDestroyNode(pLogicSubplan);
|
||||||
nodesDestroyNode(pLogicPlan);
|
nodesDestroyNode(pLogicPlan);
|
||||||
|
terrno = code;
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue