diff --git a/source/libs/parser/src/parTranslater.c b/source/libs/parser/src/parTranslater.c
index 58830e1a76..de4afc5b4b 100644
--- a/source/libs/parser/src/parTranslater.c
+++ b/source/libs/parser/src/parTranslater.c
@@ -9922,7 +9922,10 @@ static int32_t buildNormalTableBatchReq(int32_t acctId, const SCreateTableStmt*
       int8_t valid = setColCompressByOption(
           pScheam->type, &req.colCmpr.pColCmpr[index].alg, columnEncodeVal(pColDef->pOptions->encode),
           columnCompressVal(pColDef->pOptions->compress), columnLevelVal(pColDef->pOptions->compressLevel));
-      if (!valid) return TSDB_CODE_TSC_ENCODE_PARAM_ERROR;
+      if (!valid) {
+        tdDestroySVCreateTbReq(&req);
+        return TSDB_CODE_TSC_ENCODE_PARAM_ERROR;
+      }
     }
     ++index;
   }