diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index b10b040c7b5c821f6e31270c235b4fd34a90aef7..eeea513c913dde6102502d7f392bbd61f5bf344d 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -609,7 +609,7 @@ static int32_t tscEstimateQueryMsgSize(SSqlObj *pSql, int32_t clauseIndex) {
   }
 
   return MIN_QUERY_MSG_PKT_SIZE + minMsgSize() + sizeof(SQueryTableMsg) + srcColListSize + exprSize + tsBufSize +
-         tableSerialize + sqlLen + 4096;
+         tableSerialize + sqlLen + 4096 + pQueryInfo->bufLen;
 }
 
 static char *doSerializeTableInfo(SQueryTableMsg* pQueryMsg, SSqlObj *pSql, char *pMsg) {