diff --git a/src/common/src/tdataformat.c b/src/common/src/tdataformat.c
index 3f4e13e341fd5497304a3c7616d45121b3a656ca..d52b08ffd3cc443563264899e9d4eafbcce67d29 100644
--- a/src/common/src/tdataformat.c
+++ b/src/common/src/tdataformat.c
@@ -71,7 +71,7 @@ int tdEncodeSchema(void **buf, STSchema *pSchema) {
     STColumn *pCol = schemaColAt(pSchema, i);
     tlen += taosEncodeFixedI8(buf, colType(pCol));
     tlen += taosEncodeFixedI16(buf, colColId(pCol));
-    tlen += taosEncodeFixedI16(buf, colBytes(pCol));
+    tlen += taosEncodeFixedU16(buf, colBytes(pCol));
   }
 
   return tlen;