From 7dfa4c210528c52f33daa6db070106f3a5dcd091 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 6 May 2023 13:13:28 +0800 Subject: [PATCH] fix(query): fix syntax error. --- source/dnode/vnode/src/tsdb/tsdbRead.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbRead.c b/source/dnode/vnode/src/tsdb/tsdbRead.c index 13c6e66b27..b7ec7bb5c5 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead.c @@ -3164,8 +3164,8 @@ static int32_t doBuildDataBlock(STsdbReader* pReader) { SFileDataBlockInfo* pBlockInfo = getCurrentBlockInfo(pBlockIter); SLastBlockReader* pLastBlockReader = pReader->status.fileIter.pLastBlockReader; - if (pReader->flag == READER_STATUS_SHOULD_STOP) { - return TSDB_CODE_SUCCESS; + if (pReader->code != TSDB_CODE_SUCCESS) { + return pReader->code; } pScanInfo = getTableBlockScanInfo(pReader->status.pTableMap, pBlockInfo->uid, pReader->idStr); @@ -5083,7 +5083,7 @@ static SSDataBlock* doRetrieveDataBlock(STsdbReader* pReader) { int32_t code = TSDB_CODE_SUCCESS; SFileDataBlockInfo* pBlockInfo = getCurrentBlockInfo(&pStatus->blockIter); - if (pReader->flag == READER_STATUS_SHOULD_STOP) { + if (pReader->code != TSDB_CODE_SUCCESS) { return NULL; } -- GitLab