Skip to content

Commit

Permalink
apply comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Defined2014 committed Oct 21, 2022
1 parent 7f4dbdb commit a88390a
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions executor/infoschema_reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -1713,7 +1713,10 @@ func (e *memtableRetriever) setDataForTiKVRegionStatus(ctx sessionctx.Context) (
for _, tableID := range extractorTableIDs {
regionsInfo, err := e.getRegionsInfoForTable(tikvHelper, is, tableID)
if err != nil {
continue
if errors.ErrorEqual(err, infoschema.ErrTableExists) {
continue
}
return err
}
allRegionsInfo = allRegionsInfo.Merge(regionsInfo)
}
Expand All @@ -1736,11 +1739,8 @@ func (e *memtableRetriever) setDataForTiKVRegionStatus(ctx sessionctx.Context) (
if len(extractorTableIDs) == 0 {
e.setNewTiKVRegionStatusCol(&allRegionsInfo.Regions[i], &regionTableList[j])
}
for _, tableID := range extractorTableIDs {
if tableID == regionTableList[j].Table.ID {
e.setNewTiKVRegionStatusCol(&allRegionsInfo.Regions[i], &regionTableList[j])
break
}
if slices.Contains(extractorTableIDs, regionTableList[j].Table.ID) {
e.setNewTiKVRegionStatusCol(&allRegionsInfo.Regions[i], &regionTableList[j])
}
}
}
Expand Down

0 comments on commit a88390a

Please sign in to comment.