diff --git a/source/dnode/vnode/src/tsdb/tsdbRead.c b/source/dnode/vnode/src/tsdb/tsdbRead.c
index 41e591c5b216325f34fe4a4a6475e79a941c3fdb..652b38a86c97672804b9794ff7b5d8cb868b6e0b 100644
--- a/source/dnode/vnode/src/tsdb/tsdbRead.c
+++ b/source/dnode/vnode/src/tsdb/tsdbRead.c
@@ -1929,9 +1929,9 @@ int32_t getEndPosInDataBlock(STsdbReadHandle* pTsdbReadHandle, SDataBlockInfo* p
     }
   } else {
     if (ascScan && pTsdbReadHandle->window.ekey >= pBlockInfo->window.ekey) {
-      endPos = MIN(cur->pos + pTsdbReadHandle->outputCapacity - 1, pBlockInfo->rows - 1);
+      endPos = TMIN(cur->pos + pTsdbReadHandle->outputCapacity - 1, pBlockInfo->rows - 1);
     } else if ((!ascScan) && pTsdbReadHandle->window.ekey <= pBlockInfo->window.skey) {
-      endPos = MAX(cur->pos - pTsdbReadHandle->outputCapacity + 1, 0);
+      endPos = TMAX(cur->pos - pTsdbReadHandle->outputCapacity + 1, 0);
     } else {
       ASSERT(pCols->numOfRows > 0);
       endPos = doBinarySearchKey(pCols->cols[0].pData, pCols->numOfRows, pTsdbReadHandle->window.ekey, order);