From 8266c4ff779773756a2948a519676a2cb3bbc99e Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Mon, 9 Oct 2023 15:26:42 +0800 Subject: [PATCH] fix(stream): remove invalid clear of rspmsg list. --- source/dnode/vnode/src/tq/tq.c | 1 + source/libs/stream/src/streamCheckpoint.c | 1 - 2 files changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 2c83f91713..a1120fdaa1 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1940,6 +1940,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); } diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c index a26d667421..2cde368195 100644 --- a/source/libs/stream/src/streamCheckpoint.c +++ b/source/libs/stream/src/streamCheckpoint.c @@ -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 }