fix(stream): remove invalid clear of rspmsg list.
This commit is contained in:
parent
847baa8b71
commit
af4618f958
|
@ -1932,6 +1932,7 @@ int32_t tqProcessTaskResetReq(STQ* pTq, SRpcMsg* pMsg) {
|
|||
// clear flag set during do checkpoint, and open inputQ for all upstream tasks
|
||||
if (pTask->status.taskStatus == TASK_STATUS__CK) {
|
||||
streamTaskClearCheckInfo(pTask);
|
||||
taosArrayClear(pTask->pReadyMsgList);
|
||||
streamSetStatusNormal(pTask);
|
||||
}
|
||||
|
||||
|
|
|
@ -270,7 +270,6 @@ void streamTaskClearCheckInfo(SStreamTask* pTask) {
|
|||
pTask->chkInfo.startTs = 0; // clear the recorded start time
|
||||
pTask->checkpointNotReadyTasks = 0;
|
||||
pTask->checkpointAlignCnt = 0;
|
||||
taosArrayClear(pTask->pReadyMsgList);
|
||||
streamTaskOpenAllUpstreamInput(pTask); // open inputQ for all upstream tasks
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue