From 7a2f48fe4f2b46ee5d734a53aaaa39cca1687d05 Mon Sep 17 00:00:00 2001 From: Vicky Date: Fri, 6 Mar 2026 03:34:39 +0800 Subject: [PATCH] core/filtermaps: close batch after write in map renderer --- core/filtermaps/map_renderer.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/core/filtermaps/map_renderer.go b/core/filtermaps/map_renderer.go index e1284a3829..768f7bdd3c 100644 --- a/core/filtermaps/map_renderer.go +++ b/core/filtermaps/map_renderer.go @@ -410,6 +410,7 @@ func (r *mapRenderer) writeFinishedMaps(pauseCb func() bool) error { if err := batch.Write(); err != nil { log.Crit("Error writing log index update batch", "error", err) } + batch.Close() // do not exit while in partially written state but do allow processing // events and pausing while block processing is in progress r.f.indexLock.Unlock() @@ -509,6 +510,7 @@ func (r *mapRenderer) writeFinishedMaps(pauseCb func() bool) error { if err := batch.Write(); err != nil { log.Crit("Error writing log index update batch", "error", err) } + batch.Close() totalTime += time.Since(start) mapWriteTimer.Update(totalTime) return nil