From b06826fc5f3f350bee2ab3aacb9478b8f0ff0d4d Mon Sep 17 00:00:00 2001 From: CharlesCheung Date: Wed, 1 Nov 2023 14:14:31 +0800 Subject: [PATCH] release resolvedTs in changefeed --- cdc/owner/changefeed.go | 1 + 1 file changed, 1 insertion(+) diff --git a/cdc/owner/changefeed.go b/cdc/owner/changefeed.go index d7e5e18af1a..d4968e61e93 100644 --- a/cdc/owner/changefeed.go +++ b/cdc/owner/changefeed.go @@ -747,6 +747,7 @@ func (c *changefeed) releaseResources(ctx cdcContext.Context) { c.cleanupMetrics() c.schema = nil c.barriers = nil + c.resolvedTs = 0 c.initialized = false c.isReleased = true