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
 }