update opt

pkg/vm/engine/tae/db/checkpoint/option.go

@@ -89,3 +89,9 @@ func WithReserveWALEntryCount(count uint64) Option {
 		r.options.reservedWALEntryCount = count
 	}
 }
+
+func WithStartupLatancy(latency time.Duration) Option {
+	return func(r *runner) {
+		r.options.startupLatency = latency
+	}
+}

pkg/vm/engine/tae/db/checkpoint/runner.go

@@ -193,6 +193,8 @@ type runner struct {
 		checkpointBlockRows int
 		checkpointSize      int
 
+		startupLatency time.Duration
+
 		reservedWALEntryCount uint64
 	}
 
@@ -768,8 +770,8 @@ func (r *runner) tryScheduleCheckpoint(endts types.TS) {
 		logutil.Infof("Checkpoint is disable")
 		return
 	}
-	if time.Since(r.openTime) < time.Minute*5 {
-		logutil.Infof("Checkpoint is disable. TN has been running for %v", time.Since(r.openTime))
+	if time.Since(r.openTime) < r.options.startupLatency {
+		logutil.Infof("Checkpoint is disable. TN has been running for %v, startup latency %v", time.Since(r.openTime), r.options.startupLatency)
 		return
 	}
 	entry := r.MaxCheckpoint()
@@ -859,6 +861,9 @@ func (r *runner) fillDefaults() {
 	if r.options.checkpointSize <= 0 {
 		r.options.checkpointSize = logtail.DefaultCheckpointSize
 	}
+	if r.options.startupLatency <= 0 {
+		r.options.startupLatency = time.Minute * 5
+	}
 }
 
 func (r *runner) onWaitWaitableItems(items ...any) {

pkg/vm/engine/tae/db/open.go

@@ -163,7 +163,8 @@ func Open(ctx context.Context, dirname string, opts *options.Options) (db *DB, e
 		checkpoint.WithMinIncrementalInterval(opts.CheckpointCfg.IncrementalInterval),
 		checkpoint.WithGlobalMinCount(int(opts.CheckpointCfg.GlobalMinCount)),
 		checkpoint.WithGlobalVersionInterval(opts.CheckpointCfg.GlobalVersionInterval),
-		checkpoint.WithReserveWALEntryCount(opts.CheckpointCfg.ReservedWALEntryCount))
+		checkpoint.WithReserveWALEntryCount(opts.CheckpointCfg.ReservedWALEntryCount),
+		checkpoint.WithStartupLatancy(opts.CheckpointCfg.StartupLatency))
 
 	now := time.Now()
 	checkpointed, ckpLSN, valid, err := db.BGCheckpointRunner.Replay(dataFactory)

pkg/vm/engine/tae/options/cfg.go

@@ -47,6 +47,7 @@ type CheckpointCfg struct {
 	GCCheckpointInterval      time.Duration
 	DisableGCCheckpoint       bool
 	ReservedWALEntryCount     uint64
+	StartupLatency            time.Duration
 
 	// only for test
 	// it is used to control the block rows of the checkpoint

pkg/vm/engine/tae/testutils/config/options.go

@@ -35,6 +35,7 @@ func WithQuickScanAndCKPOpts2(in *options.Options, factor int) (opts *options.Op
 	opts.CheckpointCfg.MinCount = int64(factor)
 	opts.CheckpointCfg.IncrementalInterval *= time.Duration(factor)
 	opts.CheckpointCfg.BlockRows = 10
+	opts.CheckpointCfg.StartupLatency = time.Millisecond
 	opts.Ctx = context.Background()
 	return opts
 }
@@ -54,6 +55,7 @@ func WithQuickScanAndCKPOpts(in *options.Options) (opts *options.Options) {
 	opts.CheckpointCfg.GCCheckpointInterval = time.Millisecond * 10
 	opts.CheckpointCfg.BlockRows = 10
 	opts.CheckpointCfg.GlobalVersionInterval = time.Millisecond * 10
+	opts.CheckpointCfg.StartupLatency = time.Millisecond
 	opts.GCCfg = new(options.GCCfg)
 	opts.GCCfg.ScanGCInterval = time.Millisecond * 10
 	opts.GCCfg.GCTTL = time.Millisecond * 1
@@ -76,6 +78,7 @@ func WithQuickScanAndCKPAndGCOpts(in *options.Options) (opts *options.Options) {
 	opts.CheckpointCfg.IncrementalInterval = time.Millisecond * 20
 	opts.CheckpointCfg.GlobalMinCount = 1
 	opts.CheckpointCfg.BlockRows = 10
+	opts.CheckpointCfg.StartupLatency = time.Millisecond
 
 	opts.GCCfg = new(options.GCCfg)
 	// ScanGCInterval does not need to be too fast, because manual gc will be performed in the case
@@ -100,6 +103,7 @@ func WithOpts(in *options.Options, factor float64) (opts *options.Options) {
 	opts.CheckpointCfg.IncrementalInterval = time.Second * 2 * time.Duration(factor)
 	opts.CheckpointCfg.GlobalMinCount = 10
 	opts.CheckpointCfg.BlockRows = 10
+	opts.CheckpointCfg.StartupLatency = time.Millisecond
 	opts.Ctx = context.Background()
 	return opts
 }