diff --git a/src/query/src/qExecutor.c b/src/query/src/qExecutor.c index cfef95ef00e875c5c6e9e12f7e3de13320fcb832..6291ef53f54b3363bf8f2abb13e99306191c3d88 100644 --- a/src/query/src/qExecutor.c +++ b/src/query/src/qExecutor.c @@ -4785,12 +4785,13 @@ static bool multiTableMultioutputHelper(SQInfo *pQInfo, int32_t index) { if (elem1.vnode < 0) { return false; } - } - - tsBufSetCursor(pRuntimeEnv->pTSBuf, &pRuntimeEnv->cur); + } else { + tsBufSetCursor(pRuntimeEnv->pTSBuf, &pRuntimeEnv->cur); STSCursor cur = tsBufGetCursor(pRuntimeEnv->pTSBuf); qDebug("QInfo:%p continue scan ts_comp file, tag:%s blockIndex:%d, tsIndex:%d", pQInfo, pRuntimeEnv->pCtx[0].tag.pz, cur.blockIndex, cur.tsIndex); + } + } }