From 74bbe989194a126ab16e5d5d07fb5cb3e95dad9d Mon Sep 17 00:00:00 2001 From: 3AceShowHand Date: Thu, 31 Aug 2023 16:28:13 +0800 Subject: [PATCH] use table dispatcher as the default. --- cdc/sink/dmlsink/mq/dispatcher/partition/default.go | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) 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) }