diff --git a/source/libs/executor/src/executil.c b/source/libs/executor/src/executil.c index 05c9f8a9b0f4330b95a5d6a8e342ed22e3a2bf64..dbef0320419431c9da67de833e9627d896256a45 100644 --- a/source/libs/executor/src/executil.c +++ b/source/libs/executor/src/executil.c @@ -1666,7 +1666,6 @@ uint64_t getTotalTables(const STableListInfo* pTableList) { uint64_t getTableGroupId(const STableListInfo* pTableList, uint64_t tableUid) { if (pTableList->oneTableForEachGroup) { - ASSERT(pTableList->map == NULL); return tableUid; } diff --git a/source/libs/executor/src/scanoperator.c b/source/libs/executor/src/scanoperator.c index 5f470ea793ef54826c4b404b05b2ed969213d6cf..e8a67cdc35fcac4ce4f5c3eafd3df13eb9b6e901 100644 --- a/source/libs/executor/src/scanoperator.c +++ b/source/libs/executor/src/scanoperator.c @@ -821,7 +821,7 @@ static void destroyTableScanOperatorInfo(void* param) { taosMemoryFreeClear(param); } -SOperatorInfo* createTableScanOperatorInfo(STableScanPhysiNode* pTableScanNode, SReadHandle* readHandle, +SOperatorInfo* createTableScanOperatorInfo(STableScanPhysiNode* pTableScanNode, SReadHandle* readHandle, SExecTaskInfo* pTaskInfo) { STableScanInfo* pInfo = taosMemoryCalloc(1, sizeof(STableScanInfo)); SOperatorInfo* pOperator = taosMemoryCalloc(1, sizeof(SOperatorInfo));