[TD-5623]<feature>: fixed crash caused by second dnodeFetchQ thread try access

pRuntimeEnv->outputbuf NULL pointer issue
This commit is contained in:
Ganlin Zhao 2021-08-12 09:49:31 +08:00
parent 8a140660a4
commit 8eb1af221f
2 changed files with 5 additions and 1 deletions

View File

@ -8864,6 +8864,10 @@ bool checkNeedToCompressQueryCol(SQInfo *pQInfo) {
SSDataBlock* pRes = pRuntimeEnv->outputBuf;
if (GET_NUM_OF_RESULTS(&(pQInfo->runtimeEnv)) <= 0) {
return false;
}
int32_t numOfRows = pQueryAttr->pExpr2 ? GET_NUM_OF_RESULTS(pRuntimeEnv) : pRes->info.rows;
int32_t numOfCols = pQueryAttr->pExpr2 ? pQueryAttr->numOfExpr2 : pQueryAttr->numOfOutput;

View File

@ -357,7 +357,7 @@ int32_t qDumpRetrieveResult(qinfo_t qinfo, SRetrieveTableRsp **pRsp, int32_t *co
}
(*pRsp)->precision = htons(pQueryAttr->precision);
(*pRsp)->compressed = checkNeedToCompressQueryCol(pQInfo);
(*pRsp)->compressed = (int8_t)checkNeedToCompressQueryCol(pQInfo);
if (GET_NUM_OF_RESULTS(&(pQInfo->runtimeEnv)) > 0 && pQInfo->code == TSDB_CODE_SUCCESS) {
doDumpQueryResult(pQInfo, (*pRsp)->data, (*pRsp)->compressed, &compLen);