From 9feb0a86d643f2e5ca29f5a7e47364032937d74c Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 15 May 2023 12:46:00 +0800 Subject: [PATCH] fix(tmq): assert after the assignment of value. --- source/dnode/vnode/src/tq/tqRead.c | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tqRead.c b/source/dnode/vnode/src/tq/tqRead.c index 1ce609e666..9b6d97d6e2 100644 --- a/source/dnode/vnode/src/tq/tqRead.c +++ b/source/dnode/vnode/src/tq/tqRead.c @@ -602,12 +602,11 @@ int32_t tqRetrieveDataBlock(STqReader* pReader, SSubmitTbData** pSubmitTbDataRet return -1; } - ASSERT(pReader->cachedSchemaVer == pReader->pSchemaWrapper->version); - pReader->cachedSchemaUid = uid; pReader->cachedSchemaSuid = suid; pReader->cachedSchemaVer = sversion; + ASSERT(pReader->cachedSchemaVer == pReader->pSchemaWrapper->version); if (blockDataGetNumOfCols(pBlock) == 0) { int32_t code = buildResSDataBlock(pReader->pResBlock, pReader->pSchemaWrapper, pReader->pColIdList); if (code != TSDB_CODE_SUCCESS) { -- GitLab