From 5307f157667db6c021a0c2d99b14658e80da4835 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 16 May 2024 19:54:29 +0800 Subject: [PATCH] refactor: do some internal refactor. --- source/dnode/vnode/src/tsdb/tsdbRead2.c | 4 +--- source/libs/executor/src/dataDispatcher.c | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/source/dnode/vnode/src/tsdb/tsdbRead2.c b/source/dnode/vnode/src/tsdb/tsdbRead2.c index c25deb0d66..9d08ff4e04 100644 --- a/source/dnode/vnode/src/tsdb/tsdbRead2.c +++ b/source/dnode/vnode/src/tsdb/tsdbRead2.c @@ -4242,13 +4242,11 @@ int32_t tsdbReaderOpen2(void* pVnode, SQueryTableDataCond* pCond, void* pTableLi SVnodeCfg* pConf = &(((SVnode*)pVnode)->config); int32_t capacity = pConf->tsdbCfg.maxRows; + capacity = 8192; // for debug purpose if (pResBlock != NULL) { blockDataEnsureCapacity(pResBlock, capacity); } - // for debug purpose -// capacity = 7; - int32_t code = tsdbReaderCreate(pVnode, pCond, ppReader, capacity, pResBlock, idstr); if (code != TSDB_CODE_SUCCESS) { goto _err; diff --git a/source/libs/executor/src/dataDispatcher.c b/source/libs/executor/src/dataDispatcher.c index 2c127fba12..e2126f1fc4 100644 --- a/source/libs/executor/src/dataDispatcher.c +++ b/source/libs/executor/src/dataDispatcher.c @@ -83,7 +83,7 @@ static void toDataCacheEntry(SDataDispatchHandle* pHandle, const SInputData* pIn // ASSERT(pEntry->numOfCols == *(int32_t*)(pEntry->data + 8 + 4)); { - if (pBuf->allocSize > 8192) { + if (/*pBuf->allocSize > 8192*/ 0) { char* p = taosMemoryMalloc(pBuf->allocSize); int32_t dataLen = blockEncode(pInput->pData, p, numOfCols);