diff --git a/src/client/src/tscAsync.c b/src/client/src/tscAsync.c index 473f0c18b5..132be440cf 100644 --- a/src/client/src/tscAsync.c +++ b/src/client/src/tscAsync.c @@ -25,6 +25,7 @@ #include "tutil.h" #include "tnote.h" #include "tsched.h" +#include "tschemautil.h" static void tscProcessFetchRow(SSchedMsg *pMsg); static void tscAsyncQueryRowsForNextVnode(void *param, TAOS_RES *tres, int numOfRows); @@ -490,13 +491,13 @@ void tscMeterMetaCallBack(void *param, TAOS_RES *res, int code) { if ((pQueryInfo->type & TSDB_QUERY_TYPE_STABLE_SUBQUERY) == TSDB_QUERY_TYPE_STABLE_SUBQUERY) { STableMetaInfo* pTableMetaInfo = tscGetMeterMetaInfoFromQueryInfo(pQueryInfo, 0); -// assert(pTableMetaInfo->pTableMeta->numOfTags != 0 && pTableMetaInfo->vnodeIndex >= 0 && pSql->param != NULL); + assert((tscGetNumOfTags(pTableMetaInfo->pTableMeta) != 0) && pTableMetaInfo->vnodeIndex >= 0 && pSql->param != NULL); SRetrieveSupport *trs = (SRetrieveSupport *)pSql->param; SSqlObj * pParObj = trs->pParentSqlObj; -// assert(pParObj->signature == pParObj && trs->subqueryIndex == pTableMetaInfo->vnodeIndex && -// pTableMetaInfo->pTableMeta->numOfTags != 0); + assert(pParObj->signature == pParObj && trs->subqueryIndex == pTableMetaInfo->vnodeIndex && + tscGetNumOfTags(pTableMetaInfo->pTableMeta) != 0); tscTrace("%p get metricMeta during super table query successfully", pSql); diff --git a/src/client/src/tscLocal.c b/src/client/src/tscLocal.c index 2c747dd20e..be90047f06 100644 --- a/src/client/src/tscLocal.c +++ b/src/client/src/tscLocal.c @@ -24,7 +24,7 @@ #include "qextbuffer.h" #include "tscSecondaryMerge.h" #include "tschemautil.h" -#include "tsocket.h" +#include "name.h" static void tscSetLocalQueryResult(SSqlObj *pSql, const char *val, const char *columnName, size_t valueLength); diff --git a/src/mnode/src/mgmtSuperTable.c b/src/mnode/src/mgmtSuperTable.c index 42cd1cec51..75267203de 100644 --- a/src/mnode/src/mgmtSuperTable.c +++ b/src/mnode/src/mgmtSuperTable.c @@ -15,14 +15,7 @@ #define _DEFAULT_SOURCE #include "os.h" -#include "taosmsg.h" -#include "tscompression.h" -#include "tskiplist.h" -#include "tsqlfunction.h" -#include "ttime.h" -#include "tstatus.h" -#include "tutil.h" -#include "mnode.h" + #include "mgmtAcct.h" #include "mgmtChildTable.h" #include "mgmtDb.h" @@ -33,6 +26,10 @@ #include "mgmtTable.h" #include "mgmtUser.h" #include "mgmtVgroup.h" +#include "mnode.h" + +#include "name.h" +#include "tsqlfunction.h" static void *tsSuperTableSdb; static int32_t tsSuperTableUpdateSize; diff --git a/src/mnode/src/mgmtTable.c b/src/mnode/src/mgmtTable.c index 75f93a9bfa..4a3d429743 100644 --- a/src/mnode/src/mgmtTable.c +++ b/src/mnode/src/mgmtTable.c @@ -14,8 +14,9 @@ */ #define _DEFAULT_SOURCE +#include "os.h" + #include "mgmtTable.h" -//#include "../../client/inc/tsclient.h" #include "mgmtAcct.h" #include "mgmtChildTable.h" #include "mgmtDClient.h" @@ -30,7 +31,7 @@ #include "mgmtUser.h" #include "mgmtVgroup.h" #include "mnode.h" -#include "os.h" + #include "qast.h" #include "qextbuffer.h" #include "taoserror.h" @@ -40,6 +41,7 @@ #include "tsqlfunction.h" #include "tstatus.h" #include "ttime.h" +#include "name.h" extern void *tsNormalTableSdb; extern void *tsChildTableSdb;