diff --git a/src/mnode/src/mnodeVgroup.c b/src/mnode/src/mnodeVgroup.c index c0ab75cadb29f9cf6deebdb29d02871e2de668b1..da902dd67bca035303ee4a38780fc9322d02b801 100644 --- a/src/mnode/src/mnodeVgroup.c +++ b/src/mnode/src/mnodeVgroup.c @@ -844,6 +844,9 @@ static int32_t mnodeRetrieveStatus(SShowObj *pShow, char *data, int32_t rows, vo nAvailble++; else nUnAvailble++; + + // releae pVgroup ref + mnodeDecVgroupRef(pVgroup); } // set col data diff --git a/src/query/src/qTableMeta.c b/src/query/src/qTableMeta.c index 6b459b1434b02feca06e7179f647afa75f27458d..90686142adfd965726ca3872f53ed77af07423ce 100644 --- a/src/query/src/qTableMeta.c +++ b/src/query/src/qTableMeta.c @@ -72,7 +72,7 @@ SSchema* tscGetColumnSchemaById(STableMeta* pTableMeta, int16_t colId) { } STableMeta* tscCreateTableMetaFromMsg(STableMetaMsg* pTableMetaMsg) { - //assert(pTableMetaMsg != NULL && pTableMetaMsg->numOfColumns >= 2); + assert(pTableMetaMsg != NULL && pTableMetaMsg->numOfColumns >= 1); int32_t schemaSize = (pTableMetaMsg->numOfColumns + pTableMetaMsg->numOfTags) * sizeof(SSchema); STableMeta* pTableMeta = calloc(1, sizeof(STableMeta) + schemaSize);