diff --git a/cdc/sink/dmlsink/mq/dispatcher/partition/default.go b/cdc/sink/dmlsink/mq/dispatcher/partition/default.go index 001f61449d8..9a7fba291df 100644 --- a/cdc/sink/dmlsink/mq/dispatcher/partition/default.go +++ b/cdc/sink/dmlsink/mq/dispatcher/partition/default.go @@ -20,22 +20,17 @@ import ( // DefaultDispatcher is the default partition dispatcher. type DefaultDispatcher struct { tbd *TableDispatcher - ivd *IndexValueDispatcher } // NewDefaultDispatcher creates a DefaultDispatcher. func NewDefaultDispatcher() *DefaultDispatcher { return &DefaultDispatcher{ tbd: NewTableDispatcher(), - ivd: NewIndexValueDispatcher(), } } // DispatchRowChangedEvent returns the target partition to which // a row changed event should be dispatched. func (d *DefaultDispatcher) DispatchRowChangedEvent(row *model.RowChangedEvent, partitionNum int32) int32 { - if len(row.IndexColumns) != 1 { - return d.tbd.DispatchRowChangedEvent(row, partitionNum) - } - return d.ivd.DispatchRowChangedEvent(row, partitionNum) + return d.tbd.DispatchRowChangedEvent(row, partitionNum) }