fix: snode timer

This commit is contained in:
Liu Jicong 2023-02-01 17:27:56 +08:00
parent 04b6576a51
commit 869ab0d394
1 changed files with 2 additions and 0 deletions

View File

@ -93,6 +93,8 @@ int32_t sndExpandTask(SSnode *pSnode, SStreamTask *pTask, int64_t ver) {
pTask->exec.executor = qCreateStreamExecTaskInfo(pTask->exec.qmsg, &mgHandle);
ASSERT(pTask->exec.executor);
streamSetupTrigger(pTask);
return 0;
}