From c2cc59d7f3a1a242cf325a7e10a84a5861ed5e69 Mon Sep 17 00:00:00 2001
From: slzhou <shenglian_zhou@163.com>
Date: Tue, 19 Sep 2023 09:35:30 +0800
Subject: [PATCH] fix: fix address sanitizer error

---
 source/common/src/tmsg.c | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

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;
     }
   }