From 1cef54f6cd336368b262df0edde5642c12ed0417 Mon Sep 17 00:00:00 2001 From: Ti Chi Robot Date: Thu, 23 Sep 2021 18:56:46 +0800 Subject: [PATCH] *: fix dml not replicate when add partition about partition table without valid index (#2841) (#2865) --- cdc/entry/schema_storage.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cdc/entry/schema_storage.go b/cdc/entry/schema_storage.go index 3b5ea08adcd..c5dcacc76ba 100644 --- a/cdc/entry/schema_storage.go +++ b/cdc/entry/schema_storage.go @@ -466,7 +466,7 @@ func (s *schemaSnapshot) updatePartition(tbl *model.TableInfo) error { log.Debug("add table partition success", zap.String("name", tbl.Name.O), zap.Int64("tid", id), zap.Reflect("add partition id", partition.ID)) } s.partitionTable[partition.ID] = tbl - if !tbl.ExistTableUniqueColumn() { + if !tbl.IsEligible(s.explicitTables) { s.ineligibleTableID[partition.ID] = struct{}{} } delete(oldIDs, partition.ID)