xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix crash issue

This commit is contained in:
dapan1121 2022-05-24 19:22:06 +08:00
parent efa071c9f6
commit 04238b8ff1
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/libs/scheduler/src/schJob.c
View File

@ -53,8 +53,10 @@ int32_t schInitJob(SSchJob **pSchJob, SQueryPlan *pDag, void *pTrans, SArray *pN
pJob->attr.syncSchedule = syncSchedule; pJob->attr.syncSchedule = syncSchedule;
pJob->pTrans = pTrans; pJob->pTrans = pTrans;
pJob->sql = sql; pJob->sql = sql;
pJob->userRes = *pRes; if (pRes) {
pJob->userRes = *pRes;
}
if (pNodeList != NULL) { if (pNodeList != NULL) {
pJob->nodeList = taosArrayDup(pNodeList); pJob->nodeList = taosArrayDup(pNodeList);
} }
@ -1393,7 +1395,9 @@ int32_t schExecStaticExplainJob(void *pTrans, SArray *pNodeList, SQueryPlan *pDa
pJob->attr.explainMode = pDag->explainInfo.mode; pJob->attr.explainMode = pDag->explainInfo.mode;
pJob->queryId = pDag->queryId; pJob->queryId = pDag->queryId;
pJob->subPlans = pDag->pSubplans; pJob->subPlans = pDag->pSubplans;
pJob->userRes = *pRes; if (pRes) {
pJob->userRes = *pRes;
}
SCH_ERR_JRET(qExecStaticExplain(pDag, (SRetrieveTableRsp **)&pJob->resData)); SCH_ERR_JRET(qExecStaticExplain(pDag, (SRetrieveTableRsp **)&pJob->resData));