fix(stream): add null ptr check.

This commit is contained in:
Haojun Liao 2024-02-21 09:40:22 +08:00
parent fca1c077fe
commit 8d848a5bf0
1 changed files with 4 additions and 0 deletions

View File

@ -756,6 +756,10 @@ int8_t streamTaskSetSchedStatusInactive(SStreamTask* pTask) {
}
int32_t streamTaskClearHTaskAttr(SStreamTask* pTask, int32_t resetRelHalt, bool metaLock) {
if (pTask == NULL) {
return TSDB_CODE_SUCCESS;
}
SStreamMeta* pMeta = pTask->pMeta;
STaskId sTaskId = {.streamId = pTask->streamTaskId.streamId, .taskId = pTask->streamTaskId.taskId};
if (pTask->info.fillHistory == 0) {