dispatcher: disable batch

Signed-off-by: dongmen <[email protected]>
pingcap · Nov 8, 2024 · 545e0fd · 545e0fd
1 parent c46b182
commit 545e0fd
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/downstreamadapter/dispatcher/helper.go b/downstreamadapter/dispatcher/helper.go
@@ -343,7 +343,7 @@ func GetEventDynamicStream() dynstream.DynamicStream[common.GID, common.Dispatch
 	if eventDynamicStream == nil {
 		eventDynamicStreamOnce.Do(func() {
 			option := dynstream.NewOption()
-			option.BatchCount = 128
+			//option.BatchCount = 128
 			// Enable memory control for dispatcher events dynamic stream.
 			log.Info("New EventDynamicStream, memory control is enabled")
 			option.EnableMemoryControl = true