diff --git a/pkg/causality/conflict_detector.go b/pkg/causality/conflict_detector.go
index 0ad209c5106..849bb1ed296 100644
--- a/pkg/causality/conflict_detector.go
+++ b/pkg/causality/conflict_detector.go
@@ -57,8 +57,13 @@ func NewConflictDetector[Worker worker[Txn], Txn txnEvent](
 		workers:       workers,
 		slots:         internal.NewSlots[*internal.Node](numSlots),
 		numSlots:      numSlots,
+<<<<<<< HEAD
 		notifiedNodes: chann.NewDrainableChann[func()](),
 		garbageNodes:  chann.NewDrainableChann[txnFinishedEvent](),
+=======
+		notifiedNodes: chann.NewAutoDrainChann[func()](),
+		garbageNodes:  chann.NewAutoDrainChann[txnFinishedEvent](),
+>>>>>>> e47549bd72 (sink(ticdc): Revert changes related to the conflict detector (#10897))
 		closeCh:       make(chan struct{}),
 	}