adj res
This commit is contained in:
parent
1b5cf65ab9
commit
9d64202f02
|
@ -1303,7 +1303,9 @@ static int32_t getTableScannerExecInfo(struct SOperatorInfo* pOptr, void** pOptr
|
||||||
static void destroyTableScanBase(STableScanBase* pBase, TsdReader* pAPI) {
|
static void destroyTableScanBase(STableScanBase* pBase, TsdReader* pAPI) {
|
||||||
cleanupQueryTableDataCond(&pBase->cond);
|
cleanupQueryTableDataCond(&pBase->cond);
|
||||||
|
|
||||||
pAPI->tsdReaderClose(pBase->dataReader);
|
if (pAPI->tsdReaderClose) {
|
||||||
|
pAPI->tsdReaderClose(pBase->dataReader);
|
||||||
|
}
|
||||||
pBase->dataReader = NULL;
|
pBase->dataReader = NULL;
|
||||||
|
|
||||||
if (pBase->matchInfo.pList != NULL) {
|
if (pBase->matchInfo.pList != NULL) {
|
||||||
|
|
Loading…
Reference in New Issue