fix bug: taskId should start from 0

alibaba · Jan 23, 2024 · 8776c9d · 8776c9d
1 parent 772e642
commit 8776c9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/master/task_master.go b/internal/master/task_master.go
@@ -67,7 +67,7 @@ func NewTaskMaster(actorCtx actor.Context, jobInstanceInfo *common.JobInstanceIn
 		inited:              true,
 		instanceStatus:      processor.InstanceStatusRunning,
 		taskStatusMap:       sync.Map{},
-		taskIdGenerator:     atomic.NewInt64(0),
+		taskIdGenerator:     atomic.NewInt64(-1),
 		aliveCheckWorkerSet: utils.NewConcurrentSet(),
 		jobInstanceInfo:     jobInstanceInfo,
 		actorContext:        actorCtx,