From cad8fec42e1f7a12bbe445a1d3ada79d402fa3f1 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Sat, 30 Mar 2024 13:59:45 +0000 Subject: [PATCH] Merge branch '3.0' into feature/compressData --- source/dnode/vnode/src/meta/metaTable.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/meta/metaTable.c b/source/dnode/vnode/src/meta/metaTable.c index b802d5ba38..833c611cd7 100644 --- a/source/dnode/vnode/src/meta/metaTable.c +++ b/source/dnode/vnode/src/meta/metaTable.c @@ -1490,6 +1490,7 @@ static int metaAlterTableColumn(SMeta *pMeta, int64_t version, SVAlterTbReq *pAl entry.version = version; int tlen; SSchema *pNewSchema = NULL; + SSchema tScheam; switch (pAlterTbReq->action) { case TSDB_ALTER_TABLE_ADD_COLUMN: if (pColumn) { @@ -1525,6 +1526,7 @@ static int metaAlterTableColumn(SMeta *pMeta, int64_t version, SVAlterTbReq *pAl SSchema *pCol = &pSchema->pSchema[entry.ntbEntry.schemaRow.nCols - 1]; updataTableColCmpr(&entry.colCmpr, pCol, 1); freeColCmpr = true; + ASSERT(entry.colCmpr.nCols == pSchema->nCols); break; case TSDB_ALTER_TABLE_DROP_COLUMN: if (pColumn == NULL) { @@ -1539,6 +1541,7 @@ static int metaAlterTableColumn(SMeta *pMeta, int64_t version, SVAlterTbReq *pAl terrno = TSDB_CODE_VND_COL_SUBSCRIBED; goto _err; } + memcpy(&tScheam, pColumn, sizeof(SSchema)); pSchema->version++; tlen = (pSchema->nCols - iCol - 1) * sizeof(SSchema); if (tlen) { @@ -1555,7 +1558,8 @@ static int metaAlterTableColumn(SMeta *pMeta, int64_t version, SVAlterTbReq *pAl (void)tsdbCacheDropNTableColumn(pMeta->pVnode->pTsdb, entry.uid, cid, col_type); } - updataTableColCmpr(&entry.colCmpr, pColumn, 0); + updataTableColCmpr(&entry.colCmpr, &tScheam, 0); + ASSERT(entry.colCmpr.nCols == pSchema->nCols); break; case TSDB_ALTER_TABLE_UPDATE_COLUMN_BYTES: if (pColumn == NULL) {