From 2e42af1dd0b659b0389d215c5ba95c98c9ef438e Mon Sep 17 00:00:00 2001
From: dmchen <cademfly@hotmail.com>
Date: Mon, 18 Sep 2023 18:38:54 +0800
Subject: [PATCH] ci break

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

diff --git a/source/common/src/tmsg.c b/source/common/src/tmsg.c
index 9524f93d8e..89f8d1be5d 100644
--- a/source/common/src/tmsg.c
+++ b/source/common/src/tmsg.c
@@ -6844,7 +6844,8 @@ int tEncodeSVCreateTbReq(SEncoder *pCoder, const SVCreateTbReq *pReq) {
   } else {
     ASSERT(0);
   }
-  if(pReq->sqlLen > 0) {
+  //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;
   }
@@ -6891,12 +6892,13 @@ int tDecodeSVCreateTbReq(SDecoder *pCoder, SVCreateTbReq *pReq) {
     ASSERT(0);
   }
 
+  //DECODESQL
   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 (tDecodeCStrAndLen(pCoder, &pReq->sql, &pReq->sqlLen) < 0) return -1;
+      if (tDecodeCStrTo(pCoder, pReq->sql) < 0) return -1;
     }
   }