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,