add checkpoint

This commit is contained in:
yihaoDeng 2023-06-28 09:58:07 +00:00
parent 6b6e237079
commit bb520b56e7
1 changed files with 2 additions and 1 deletions

View File

@ -24,7 +24,8 @@ static int32_t mndAddToTaskset(SArray* pArray, SStreamTask* pTask) {
return 0;
}
SStreamTask* tNewStreamTask(int64_t streamId, int8_t taskLevel, int8_t fillHistory, int64_t triggerParam, SArray* pTaskList) {
SStreamTask* tNewStreamTask(int64_t streamId, int8_t taskLevel, int8_t fillHistory, int64_t triggerParam,
SArray* pTaskList) {
SStreamTask* pTask = (SStreamTask*)taosMemoryCalloc(1, sizeof(SStreamTask));
if (pTask == NULL) {
terrno = TSDB_CODE_OUT_OF_MEMORY;