diff --git a/cdc/processor/pipeline/sink.go b/cdc/processor/pipeline/sink.go
index 872294ab2b9..ffd3d10fdb6 100644
--- a/cdc/processor/pipeline/sink.go
+++ b/cdc/processor/pipeline/sink.go
@@ -142,7 +142,6 @@ func (n *sinkNode) flushSink(ctx pipeline.NodeContext, resolvedTs model.Ts) (err
 }
 
 func (n *sinkNode) emitEvent(ctx pipeline.NodeContext, event *model.PolymorphicEvent) error {
-	n.eventBuffer = append(n.eventBuffer, event)
 	if event == nil || event.Row == nil {
 		return nil
 	}