only for memLeak
This commit is contained in:
parent
a673f500b8
commit
73fb43de2a
|
@ -371,7 +371,6 @@ static int32_t doSetInputDataBlock(SExprSupp* pExprSup, SSDataBlock* pBlock, int
|
|||
}
|
||||
if (hasPk && (j == pkParamIdx)) {
|
||||
pInput->pPrimaryKey = pInput->pData[j];
|
||||
QUERY_CHECK_CONDITION((pInput->pData[j]->pData != NULL), code, lino, _end, TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR);
|
||||
}
|
||||
QUERY_CHECK_CONDITION((pInput->pData[j] != NULL), code, lino, _end, TSDB_CODE_QRY_EXECUTOR_INTERNAL_ERROR);
|
||||
} else if (pFuncParam->type == FUNC_PARAM_TYPE_VALUE) {
|
||||
|
|
|
@ -3163,10 +3163,6 @@ static int32_t doSaveLastrow(SqlFunctionCtx* pCtx, char* pData, int32_t rowIndex
|
|||
}
|
||||
|
||||
if (pCtx->hasPrimaryKey) {
|
||||
if (colDataIsNull_s(pkCol, rowIndex)) {
|
||||
qError("primary key is null, rowIndex:%d", rowIndex);
|
||||
return TSDB_CODE_FUNC_FUNTION_ERROR;
|
||||
}
|
||||
char* pkData = colDataGetData(pkCol, rowIndex);
|
||||
if (IS_VAR_DATA_TYPE(pInfo->pkType)) {
|
||||
pInfo->pkBytes = varDataTLen(pkData);
|
||||
|
|
Loading…
Reference in New Issue