fix(stream): fix invalid assert.

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

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