fix(stream): remove invalid assert.

This commit is contained in:
Haojun Liao 2023-11-01 00:33:17 +08:00
parent 3e6c89d8eb
commit 3f561fb8e4
1 changed files with 0 additions and 3 deletions

View File

@ -309,9 +309,6 @@ int32_t streamDoTransferStateToStreamTask(SStreamTask* pTask) {
}
ETaskStatus status = streamTaskGetStatus(pStreamTask, NULL);
ASSERT(((status == TASK_STATUS__DROPPING) || (pStreamTask->hTaskInfo.id.taskId == pTask->id.taskId)) &&
pTask->status.appendTranstateBlock == true);
STimeWindow* pTimeWindow = &pStreamTask->dataRange.window;
// It must be halted for a source stream task, since when the related scan-history-data task start scan the history