From 6997386455b673a3e8863471a4034868ac19c103 Mon Sep 17 00:00:00 2001
From: yihaoDeng <luomoxyz@126.com>
Date: Wed, 27 Nov 2024 15:22:29 +0800
Subject: [PATCH] support subscribe

---
 source/client/src/clientRawBlockWrite.c | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/source/client/src/clientRawBlockWrite.c b/source/client/src/clientRawBlockWrite.c
index b209ff2eca..08ecf103cd 100644
--- a/source/client/src/clientRawBlockWrite.c
+++ b/source/client/src/clientRawBlockWrite.c
@@ -772,10 +772,13 @@ static void processAlterTable(SMqMetaRsp* metaRsp, cJSON** pJson) {
       cJSON* tags = cJSON_CreateArray();
       RAW_NULL_CHECK(tags);
       for (int32_t i = 0; i < nTags; i++) {
+        cJSON* member = cJSON_CreateObject();
+        RAW_NULL_CHECK(member);
+
         SMultiTagUpateVal* pTagVal = taosArrayGet(vAlterTbReq.pMultiTag, i);
         cJSON*             tagName = cJSON_CreateString(pTagVal->tagName);
         RAW_NULL_CHECK(tagName);
-        RAW_FALSE_CHECK(cJSON_AddItemToObject(tags, "colName", tagName));
+        RAW_FALSE_CHECK(cJSON_AddItemToObject(member, "colName", tagName));
 
         if (pTagVal->tagType == TSDB_DATA_TYPE_JSON) {
           uError("processAlterTable isJson false");
@@ -799,12 +802,13 @@ static void processAlterTable(SMqMetaRsp* metaRsp, cJSON** pJson) {
           }
           cJSON* colValue = cJSON_CreateString(buf);
           RAW_NULL_CHECK(colValue);
-          RAW_FALSE_CHECK(cJSON_AddItemToObject(tags, "colValue", colValue));
+          RAW_FALSE_CHECK(cJSON_AddItemToObject(member, "colValue", colValue));
           taosMemoryFree(buf);
         }
         cJSON* isNullCJson = cJSON_CreateBool(isNull);
         RAW_NULL_CHECK(isNullCJson);
-        RAW_FALSE_CHECK(cJSON_AddItemToObject(tags, "colValueNull", isNullCJson));
+        RAW_FALSE_CHECK(cJSON_AddItemToObject(member, "colValueNull", isNullCJson));
+        RAW_FALSE_CHECK(cJSON_AddItemToArray(tags, member));
       }
       RAW_FALSE_CHECK(cJSON_AddItemToObject(json, "tags", tags));
       break;