From cb1933baac03e307516e05fe8e6fe617b3e7720d Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Thu, 2 Nov 2023 16:58:37 +0800 Subject: [PATCH] fix meta manager flush interval. --- cdc/redo/meta_manager.go | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/cdc/redo/meta_manager.go b/cdc/redo/meta_manager.go index 3f6f0c7563a..f1ad1acac72 100644 --- a/cdc/redo/meta_manager.go +++ b/cdc/redo/meta_manager.go @@ -72,7 +72,6 @@ type metaManager struct { startTs model.Ts lastFlushTime time.Time - flushIntervalInMs int64 cfg *config.ConsistentConfig metricFlushLogDuration prometheus.Observer } @@ -94,13 +93,12 @@ func NewMetaManager( } m := &metaManager{ - captureID: config.GetGlobalServerConfig().AdvertiseAddr, - changeFeedID: changefeedID, - uuidGenerator: uuid.NewGenerator(), - enabled: true, - flushIntervalInMs: cfg.FlushIntervalInMs, - cfg: cfg, - startTs: checkpoint, + captureID: config.GetGlobalServerConfig().AdvertiseAddr, + changeFeedID: changefeedID, + uuidGenerator: uuid.NewGenerator(), + enabled: true, + cfg: cfg, + startTs: checkpoint, } return m }