br: Change default check point lag limit (#51906) (#52115)

ref #50803

br/pkg/streamhelper/config/advancer_conf.go

@@ -14,10 +14,11 @@ const (
 	flagFullScanDiffTick    = "full-scan-tick"
 	flagAdvancingByCache    = "advancing-by-cache"
 	flagTryAdvanceThreshold = "try-advance-threshold"
+	flagCheckPointLagLimit  = "check-point-lag-limit"
 
 	DefaultConsistencyCheckTick = 5
 	DefaultTryAdvanceThreshold  = 4 * time.Minute
-	DefaultCheckPointLagLimit   = 0
+	DefaultCheckPointLagLimit   = 48 * time.Hour
 	DefaultBackOffTime          = 5 * time.Second
 	DefaultTickInterval         = 12 * time.Second
 	DefaultFullScanTick         = 4
@@ -40,9 +41,14 @@ type Config struct {
 }
 
 func DefineFlagsForCheckpointAdvancerConfig(f *pflag.FlagSet) {
-	f.Duration(flagBackoffTime, DefaultBackOffTime, "The gap between two retries.")
-	f.Duration(flagTickInterval, DefaultTickInterval, "From how long we trigger the tick (advancing the checkpoint).")
-	f.Duration(flagTryAdvanceThreshold, DefaultTryAdvanceThreshold, "If the checkpoint lag is greater than how long, we would try to poll TiKV for checkpoints.")
+	f.Duration(flagBackoffTime, DefaultBackOffTime,
+		"The gap between two retries.")
+	f.Duration(flagTickInterval, DefaultTickInterval,
+		"From how long we trigger the tick (advancing the checkpoint).")
+	f.Duration(flagTryAdvanceThreshold, DefaultTryAdvanceThreshold,
+		"If the checkpoint lag is greater than how long, we would try to poll TiKV for checkpoints.")
+	f.Duration(flagCheckPointLagLimit, DefaultCheckPointLagLimit,
+		"The maximum lag could be tolerated for the checkpoint lag.")
 }
 
 func Default() Config {
@@ -68,6 +74,10 @@ func (conf *Config) GetFromFlags(f *pflag.FlagSet) error {
 	if err != nil {
 		return err
 	}
+	conf.CheckPointLagLimit, err = f.GetDuration(flagCheckPointLagLimit)
+	if err != nil {
+		return err
+	}
 	return nil
 }
 

br/pkg/task/stream.go

@@ -80,7 +80,7 @@ var (
 	StreamStatus   = "log status"
 	StreamTruncate = "log truncate"
 	StreamMetadata = "log metadata"
-	StreamCtl      = "log ctl"
+	StreamCtl      = "log advancer"
 
 	skipSummaryCommandList = map[string]struct{}{
 		StreamStatus:   {},