diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c
index 8786d30007d60f2e831625d4c947d4c3933d616d..ba895921890b868b79c0d13226b41447f725fcdf 100644
--- a/source/libs/executor/src/scanoperator.c
+++ b/source/libs/executor/src/scanoperator.c
@@ -2593,7 +2593,7 @@ static SSDataBlock* getTableDataBlock(void* param) {
     SDataBlockInfo binfo = pBlock->info;
     tsdbRetrieveDataBlockInfo(reader, &binfo);
 
-    blockDataEnsureCapacity(pBlock, binfo.capacity);
+    blockDataEnsureCapacity(pBlock, binfo.rows);
     pBlock->info.type = binfo.type;
     pBlock->info.uid = binfo.uid;
     pBlock->info.window = binfo.window;