From 8776c9d2907e6b58c0ac26616cead2d561cb0dae Mon Sep 17 00:00:00 2001 From: HuangXiaomeng Date: Mon, 22 Jan 2024 16:41:45 +0800 Subject: [PATCH] fix bug: taskId should start from 0 --- internal/master/task_master.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/master/task_master.go b/internal/master/task_master.go index d3bca1d..db2fa2e 100644 --- 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,