lightning: Change how the ID of taskCfg.TaskID is generated (pingca…

…p#55505) close pingcap#55384
ti-chi-bot · Sep 24, 2024 · 5ac6a69 · 5ac6a69
1 parent 55eefb6
commit 5ac6a69
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/br/pkg/lightning/lightning.go b/br/pkg/lightning/lightning.go
@@ -26,6 +26,7 @@ import (
 	"encoding/pem"
 	"fmt"
 	"io"
+	"math/big"
 	"net"
 	"net/http"
 	"net/http/pprof"
@@ -350,8 +351,12 @@ func (l *Lightning) RunOnceWithOptions(taskCtx context.Context, taskCfg *config.
 	if err := taskCfg.Adjust(taskCtx); err != nil {
 		return err
 	}
+	r, err := rand.Int(rand.Reader, big.NewInt(1<<63-1))
+	if err != nil {
+		return err
+	}
+	taskCfg.TaskID = r.Int64()
 
-	taskCfg.TaskID = time.Now().UnixNano()
 	failpoint.Inject("SetTaskID", func(val failpoint.Value) {
 		taskCfg.TaskID = int64(val.(int))
 	})