diff --git a/source/libs/executor/src/executorimpl.c b/source/libs/executor/src/executorimpl.c index bd93284da296b076ecdb9fbf0844ee0fcbe29a23..08521f91e8280fbd23b390bae2ed0d12b986f0d3 100644 --- a/source/libs/executor/src/executorimpl.c +++ b/source/libs/executor/src/executorimpl.c @@ -1850,12 +1850,6 @@ void setFunctionResultOutput(SOptrBasicInfo* pInfo, SAggSupporter* pSup, int32_t pCtx[i].resultInfo = pEntry; pCtx[i].scanFlag = stage; - - // set the timestamp output buffer for top/bottom/diff query - // int32_t fid = pCtx[i].functionId; - // if (fid == FUNCTION_TOP || fid == FUNCTION_BOTTOM || fid == FUNCTION_DIFF || fid == FUNCTION_DERIVATIVE) { - // if (i > 0) pCtx[i].pTsOutput = pCtx[i-1].pOutput; - // } } initCtxOutputBuffer(pCtx, pDataBlock->info.numOfCols); @@ -4672,6 +4666,8 @@ void extractTableSchemaVersion(SReadHandle *pHandle, uint64_t uid, SExecTaskInfo } else { pTaskInfo->schemaVer.sversion = mr.me.ntbEntry.schema.sver; } + + metaReaderClear(&mr); } SOperatorInfo* createOperatorTree(SPhysiNode* pPhyNode, SExecTaskInfo* pTaskInfo, SReadHandle* pHandle, diff --git a/tests/system-test/2-query/abs.py b/tests/system-test/2-query/abs.py index ccf83df952fadb274088fa2e9d296a6d955e455f..a3e976b490ff887829f880d97e3af54918ff58d8 100644 --- a/tests/system-test/2-query/abs.py +++ b/tests/system-test/2-query/abs.py @@ -13,7 +13,7 @@ class TDTestCase: "wDebugFlag":143,"sDebugFlag":143,"tsdbDebugFlag":143,"tqDebugFlag":143 ,"fsDebugFlag":143 ,"fnDebugFlag":143} def init(self, conn, logSql): tdLog.debug(f"start to excute {__file__}") - tdSql.init(conn.cursor()) + tdSql.init(conn.cursor(), True) def prepare_datas(self): tdSql.execute(