diff --git a/source/libs/parser/src/parser.c b/source/libs/parser/src/parser.c
index d22f92517d8fac2b6feba91bb65bfe0f6e07ce13..f440e6cdfe9678bbda242ac7b1047318e1be851a 100644
--- a/source/libs/parser/src/parser.c
+++ b/source/libs/parser/src/parser.c
@@ -237,6 +237,9 @@ void qParserCleanupMetaRequestInfo(SCatalogReq* pMetaReq) {
 }
 
 void qDestroyQuery(SQueryNode* pQueryNode) {
+  if (NULL == pQueryNode) {
+    return;
+  }
   if (nodeType(pQueryNode) == TSDB_SQL_INSERT || nodeType(pQueryNode) == TSDB_SQL_CREATE_TABLE) {
     SVnodeModifOpStmtInfo* pModifInfo = (SVnodeModifOpStmtInfo*)pQueryNode;
     taosArrayDestroy(pModifInfo->pDataBlocks);
diff --git a/source/libs/planner/src/physicalPlanJson.c b/source/libs/planner/src/physicalPlanJson.c
index faeed74f1a65fa05ada2c7506983b5d4f03bdf84..20da1842cf042de13f3f3628d6bcf24428184d61 100644
--- a/source/libs/planner/src/physicalPlanJson.c
+++ b/source/libs/planner/src/physicalPlanJson.c
@@ -398,7 +398,7 @@ static bool exprNodeFromJson(const cJSON* json, void* obj) {
     case TEXPR_FUNCTION_NODE:
       return fromObject(json, jkExprNodeFunction, functionFromJson, exprInfo, false);
     case TEXPR_COL_NODE:
-      return fromObject(json, jkExprNodeColumn, schemaFromJson, exprInfo->pSchema, false);
+      return fromObjectWithAlloc(json, jkExprNodeColumn, schemaFromJson, (void**)&exprInfo->pSchema, sizeof(SSchema), false);
     case TEXPR_VALUE_NODE:
       return fromObject(json, jkExprNodeValue, variantFromJson, exprInfo->pVal, false);
     default: