xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:deal with ASSERT in tmq

This commit is contained in:
wangmm0220 2023-03-11 16:51:34 +08:00
parent 9cc7a9f504
commit 0e2cf0ed73
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/dnode/vnode/src/tq/tq.c
View File

@ -933,9 +933,10 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) {
pTask->tbSink.pTSchema = pTask->tbSink.pTSchema =
tBuildTSchema(pTask->tbSink.pSchemaWrapper->pSchema, pTask->tbSink.pSchemaWrapper->nCols, version); tBuildTSchema(pTask->tbSink.pSchemaWrapper->pSchema, pTask->tbSink.pSchemaWrapper->nCols, version);
if(pTask->tbSink.pTSchema == NULL){ if(pTask->tbSink.pTSchema == NULL) {
return -1; return -1;
} }
}
streamSetupTrigger(pTask); streamSetupTrigger(pTask);