fix(query): reset fileIter when reset tsdb reader.
This commit is contained in:
parent
450173a66a
commit
280bb37270
|
@ -337,13 +337,16 @@ static int32_t initFilesetIterator(SFilesetIter* pIter, SArray* aDFileSet,
|
||||||
tsdbError("failed to prepare the last block iterator, code:%d %s", tstrerror(code), pReader->idStr);
|
tsdbError("failed to prepare the last block iterator, code:%d %s", tstrerror(code), pReader->idStr);
|
||||||
return code;
|
return code;
|
||||||
}
|
}
|
||||||
|
|
||||||
SLastBlockReader* pLReader = pIter->pLastBlockReader;
|
|
||||||
pLReader->order = pReader->order;
|
|
||||||
pLReader->window = pReader->window;
|
|
||||||
pLReader->verRange = pReader->verRange;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
SLastBlockReader* pLReader = pIter->pLastBlockReader;
|
||||||
|
pLReader->order = pReader->order;
|
||||||
|
pLReader->window = pReader->window;
|
||||||
|
pLReader->verRange = pReader->verRange;
|
||||||
|
|
||||||
|
pLReader->uid = 0;
|
||||||
|
tMergeTreeClose(&pLReader->mergeTree);
|
||||||
|
|
||||||
tsdbDebug("init fileset iterator, total files:%d %s", pIter->numOfFiles, pReader->idStr);
|
tsdbDebug("init fileset iterator, total files:%d %s", pIter->numOfFiles, pReader->idStr);
|
||||||
return TSDB_CODE_SUCCESS;
|
return TSDB_CODE_SUCCESS;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue