diff --git a/src/client/src/tscServer.c b/src/client/src/tscServer.c
index 953914c50491db0eb0bc2d7f417e1ca390cdd171..599767803c9e80c110bce2e10987d864a071ed26 100644
--- a/src/client/src/tscServer.c
+++ b/src/client/src/tscServer.c
@@ -643,6 +643,12 @@ static int32_t tscEstimateQueryMsgSize(SSqlObj *pSql, int32_t clauseIndex) {
     tableSerialize = totalTables * sizeof(STableIdInfo);
   }
 
+
+  SCond* pCond = &pQueryInfo->tagCond.tbnameCond;
+  if (pCond->len > 0) {
+    srcColListSize += pCond->len;
+  }
+
   return MIN_QUERY_MSG_PKT_SIZE + minMsgSize() + sizeof(SQueryTableMsg) + srcColListSize + srcColFilterSize +
          exprSize + tsBufSize + tableSerialize + sqlLen + 4096 + pQueryInfo->bufLen;
 }