From fb248b2682257911ea6def4d942dcdb1da4eecb7 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Mon, 13 May 2024 17:26:39 +0800
Subject: [PATCH] fix(stream): not save the stream task for rsma.

---
 source/libs/stream/src/streamCheckpoint.c | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c
index 1b6c9cc791..389eccd66d 100644
--- a/source/libs/stream/src/streamCheckpoint.c
+++ b/source/libs/stream/src/streamCheckpoint.c
@@ -469,8 +469,8 @@ int32_t streamTaskBuildCheckpoint(SStreamTask* pTask) {
     }
   }
 
-  // clear the checkpoint info, and commit the newest checkpoint info if all works are done successfully
-  if (code == TSDB_CODE_SUCCESS) {
+  // update the latest checkpoint info if all works are done successfully, for rsma, the pMsgCb is null.
+  if (code == TSDB_CODE_SUCCESS && (pTask->pMsgCb != NULL)) {
     STaskId* pHTaskId = &pTask->hTaskInfo.id;
     code = streamBuildAndSendCheckpointUpdateMsg(pTask->pMsgCb, pMeta->vgId, &pTask->id, pHTaskId, &pTask->chkInfo,
                                                  dropRelHTask);