diff --git a/source/libs/scheduler/src/schJob.c b/source/libs/scheduler/src/schJob.c
index 52722d819f9b517a468befb76ed9326ce7d0378f..d64c944994bbcb2817bb711b768242d02db71934 100644
--- a/source/libs/scheduler/src/schJob.c
+++ b/source/libs/scheduler/src/schJob.c
@@ -53,8 +53,10 @@ int32_t schInitJob(SSchJob **pSchJob, SQueryPlan *pDag, void *pTrans, SArray *pN
   pJob->attr.syncSchedule = syncSchedule;
   pJob->pTrans = pTrans;
   pJob->sql = sql;
-  pJob->userRes = *pRes;
-
+  if (pRes) {
+    pJob->userRes = *pRes;
+  }
+  
   if (pNodeList != NULL) {
     pJob->nodeList = taosArrayDup(pNodeList);
   }
@@ -1393,7 +1395,9 @@ int32_t schExecStaticExplainJob(void *pTrans, SArray *pNodeList, SQueryPlan *pDa
   pJob->attr.explainMode = pDag->explainInfo.mode;
   pJob->queryId = pDag->queryId;
   pJob->subPlans = pDag->pSubplans;
-  pJob->userRes = *pRes;
+  if (pRes) {
+    pJob->userRes = *pRes;
+  }
   
   SCH_ERR_JRET(qExecStaticExplain(pDag, (SRetrieveTableRsp **)&pJob->resData));