Resolve conflicts

pingcap · Aug 1, 2021 · 1ca0695 · 1ca0695
1 parent 8f459a9
commit 1ca0695
Showing 1 changed file with 0 additions and 1 deletion.
diff --git 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
 	}