fix(stream): restore from the crash.
This commit is contained in:
parent
aee0460daf
commit
80d027da19
|
@ -1175,7 +1175,11 @@ int32_t tqProcessTaskCheckPointSourceReq(STQ* pTq, SRpcMsg* pMsg, SRpcMsg* pRsp)
|
||||||
return TSDB_CODE_SUCCESS;
|
return TSDB_CODE_SUCCESS;
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
ASSERT(status == TASK_STATUS__HALT);
|
// ASSERT(status == TASK_STATUS__HALT);
|
||||||
|
if (status != TASK_STATUS__HALT) {
|
||||||
|
tqError("s-task:%s should in halt status, let's halt it directly", pTask->id.idStr);
|
||||||
|
streamTaskHandleEvent(pTask->status.pSM, TASK_EVENT_HALT);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// check if the checkpoint msg already sent or not.
|
// check if the checkpoint msg already sent or not.
|
||||||
|
|
Loading…
Reference in New Issue