diff --git a/src/query/src/qTsbuf.c b/src/query/src/qTsbuf.c
index 30cf070c0af58feb83370cc67f7b83be5a134ddd..95fd88f1d89a2bd8253abc286e2787b9f0fb74cb 100644
--- a/src/query/src/qTsbuf.c
+++ b/src/query/src/qTsbuf.c
@@ -979,7 +979,7 @@ int32_t tsBufGetNumOfVnodes(STSBuf* pTSBuf) {
 }
 
 void tsBufGetVnodeIdList(STSBuf* pTSBuf, int32_t* num, int32_t** vnodeId) {
-  int32_t size = tsBugGetNumOfVnodes(pTSBuf);
+  int32_t size = tsBufGetNumOfVnodes(pTSBuf);
   if (num != NULL) {
     *num = size;
   }
@@ -989,7 +989,7 @@ void tsBufGetVnodeIdList(STSBuf* pTSBuf, int32_t* num, int32_t** vnodeId) {
     return;
   }
 
-  (*vnodeId) = malloc(tsBugGetNumOfVnodes(pTSBuf) * sizeof(int32_t));
+  (*vnodeId) = malloc(tsBufGetNumOfVnodes(pTSBuf) * sizeof(int32_t));
 
   for(int32_t i = 0; i < size; ++i) {
     (*vnodeId)[i] = pTSBuf->pData[i].info.vnode;