From 81d3e5737ec0f8ab37a1f966d672d892565bac2b Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 15 Nov 2023 16:31:07 +0800
Subject: [PATCH] fix(stream): fix send msg error.

---
 source/libs/stream/src/streamDispatch.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/libs/stream/src/streamDispatch.c b/source/libs/stream/src/streamDispatch.c
index b2f47c6d2a..1f9b21becc 100644
--- a/source/libs/stream/src/streamDispatch.c
+++ b/source/libs/stream/src/streamDispatch.c
@@ -1159,7 +1159,7 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
         { // send checkpoint failure msg to mnode directly
           pTask->chkInfo.failedId = pTask->checkpointingId;   // record the latest failed checkpoint id
           pTask->checkpointingId = pTask->checkpointingId;
-          streamTaskSendCheckpointReadyMsg(pTask);
+          streamTaskSendCheckpointSourceRsp(pTask);
         }
       } else {
         stError("s-task:%s downstream task:0x%x(vgId:%d) refused the dispatch msg, treat it as success", id,