*: fix dml not replicate when add partition about partition table wit…

…hout valid index (#2841) (#2866)
pingcap · Sep 23, 2021 · 07576ec · 07576ec
1 parent f06bbdc
commit 07576ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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)