fix: fix index not update issue

This commit is contained in:
dapan1121 2022-12-30 17:47:06 +08:00
parent ad777cc793
commit d674bae88e
1 changed files with 1 additions and 0 deletions

View File

@ -451,6 +451,7 @@ int32_t createDataInserter(SDataSinkManager* pManager, const SDataSinkNode* pDat
if (inserter->fullOrderColList && pCol->colId != inserter->pSchema->columns[i].colId) { if (inserter->fullOrderColList && pCol->colId != inserter->pSchema->columns[i].colId) {
inserter->fullOrderColList = false; inserter->fullOrderColList = false;
} }
++i;
} }
tsem_init(&inserter->ready, 0, 0); tsem_init(&inserter->ready, 0, 0);