From 91dd3b94fca082a6d514a7a606a087c158857b44 Mon Sep 17 00:00:00 2001 From: lidezhu Date: Tue, 26 Nov 2024 21:23:05 +0800 Subject: [PATCH] fix --- logservice/eventstore/event_store.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/logservice/eventstore/event_store.go b/logservice/eventstore/event_store.go index 16dbbba6..e0b48b87 100644 --- a/logservice/eventstore/event_store.go +++ b/logservice/eventstore/event_store.go @@ -232,7 +232,7 @@ func New( } option := dynstream.NewOption() - option.BatchCount = 40960 + option.BatchCount = 4096 ds := dynstream.NewParallelDynamicStream(streamCount, pathHasher{}, &eventsHandler{}, option) ds.Start()