diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index c726311d72..c5496cffb0 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -6849,7 +6849,7 @@ int tEncodeSVCreateTbReq(SEncoder *pCoder, const SVCreateTbReq *pReq) {
   //ENCODESQL
   if(pReq->sqlLen > 0 && pReq->sql != NULL) {
     if (tEncodeI32(pCoder, pReq->sqlLen) < 0) return -1;
-    if (tEncodeCStrWithLen(pCoder, pReq->sql, pReq->sqlLen) < 0) return -1;
+    if (tEncodeBinary(pCoder, pReq->sql, pReq->sqlLen) < 0) return -1;
   }
 
   tEndEncode(pCoder);
@@ -6898,9 +6898,7 @@ int tDecodeSVCreateTbReq(SDecoder *pCoder, SVCreateTbReq *pReq) {
   if(!tDecodeIsEnd(pCoder)){
     if(tDecodeI32(pCoder, &pReq->sqlLen) < 0) return -1;
     if(pReq->sqlLen > 0){
-      pReq->sql = taosMemoryCalloc(1, pReq->sqlLen + 1);
-      if (pReq->sql == NULL) return -1;
-      if (tDecodeCStrTo(pCoder, pReq->sql) < 0) return -1;
+      if (tDecodeBinaryAlloc(pCoder, (void**)&pReq->sql, NULL) < 0) return -1;
     }
   }