sink(ticdc): fix test

pingcap · Mar 3, 2022 · 5492128 · 5492128
1 parent c39549d
commit 5492128
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/cdc/entry/schema_storage.go b/cdc/entry/schema_storage.go
@@ -148,7 +148,7 @@ func newSchemaSnapshotFromMeta(meta *timeta.Meta, currentTs uint64, forceReplica
 			snap.tableInSchema[schemaID] = append(snap.tableInSchema[schemaID], tableInfo.ID)
 			tableInfo := model.WrapTableInfo(dbinfo.ID, dbinfo.Name.O, currentTs, tableInfo)
 			snap.tables[tableInfo.ID] = tableInfo
-			snap.tableNameToID[model.TableName{Schema: dbinfo.Name.O, Table: tableInfo.Name.O}] = tableInfo.ID
+			snap.tableNameToID[model.TableName{Schema: dbinfo.Name.O, Table: tableInfo.Name.O, TableID: tableInfo.ID, IsPartition: tableInfo.GetPartitionInfo() != nil}] = tableInfo.ID
 			isEligible := tableInfo.IsEligible(forceReplicate)
 			if !isEligible {
 				snap.ineligibleTableID[tableInfo.ID] = struct{}{}