fix flush interval

pingcap · Nov 2, 2023 · 4e22abd · 4e22abd
1 parent 896dbda
commit 4e22abd
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/cdc/redo/meta_manager.go b/cdc/redo/meta_manager.go
@@ -72,6 +72,7 @@ type metaManager struct {
 	startTs model.Ts
 
 	lastFlushTime          time.Time
+	flushIntervalInMs      int64
 	cfg                    *config.ConsistentConfig
 	metricFlushLogDuration prometheus.Observer
 }
@@ -93,12 +94,13 @@ func NewMetaManager(
 	}
 
 	m := &metaManager{
-		captureID:     config.GetGlobalServerConfig().AdvertiseAddr,
-		changeFeedID:  changefeedID,
-		uuidGenerator: uuid.NewGenerator(),
-		enabled:       true,
-		cfg:           cfg,
-		startTs:       checkpoint,
+		captureID:         config.GetGlobalServerConfig().AdvertiseAddr,
+		changeFeedID:      changefeedID,
+		uuidGenerator:     uuid.NewGenerator(),
+		enabled:           true,
+		flushIntervalInMs: cfg.FlushIntervalInMs,
+		cfg:               cfg,
+		startTs:           checkpoint,
 	}
 	return m
 }