From 62a763ead3cb23b9845fc1e15a6fc0ae1d6b5527 Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Tue, 11 Jul 2023 11:22:48 +0800
Subject: [PATCH] fix(stream): fix invalid assert.

---
 source/libs/stream/src/streamCheckpoint.c | 1 -
 source/libs/stream/src/streamExec.c       | 7 -------
 2 files changed, 8 deletions(-)

diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c
index e421a5d671..0557936a83 100644
--- a/source/libs/stream/src/streamCheckpoint.c
+++ b/source/libs/stream/src/streamCheckpoint.c
@@ -121,7 +121,6 @@ static int32_t streamAlignCheckpoint(SStreamTask* pTask, int64_t checkpointId, i
     pTask->checkpointingId = checkpointId;
   }
 
-  ASSERT(pTask->checkpointingId == checkpointId);
   return atomic_sub_fetch_32(&pTask->checkpointAlignCnt, 1);
 }
 
diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index c882b719bc..5b03db6f0c 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -541,13 +541,6 @@ int32_t streamTryExec(SStreamTask* pTask) {
                pTask->checkpointingId);
       }
 
-      if (pTask->info.taskLevel != TASK_LEVEL__SINK) {
-//        code = updateCheckPointInfo(pTask, pTask->checkpointingId);
-//        if (code != TSDB_CODE_SUCCESS) {
-//          return code;
-//        }
-      }
-
       // send check point response to upstream task
       if (pTask->info.taskLevel == TASK_LEVEL__SOURCE) {
         code = streamTaskSendCheckpointSourceRsp(pTask);