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);