Update controller/cluster.go

git-hulk · web-flow · commit bc722751be0f · 2025-10-04T15:34:18.000+08:00
diff --git a/controller/cluster.go b/controller/cluster.go
@@ -339,7 +339,8 @@ func (c *ClusterChecker) tryUpdateMigrationStatus(ctx context.Context, clonedClu
 			continue
 		}
 
-		// If there is no migration information on the source node or source node migratingslot is not eauqls shard, you need to clear the migration information on the controller.
+		// If there is no migration information on the source node or the source node migration slot is not equal to the shard,
+		// you need to clear the migration information on the controller.
 		if sourceNodeClusterInfo.MigratingSlot == nil || (sourceNodeClusterInfo.MigratingSlot != nil &&
 			!sourceNodeClusterInfo.MigratingSlot.Equal(shard.MigratingSlot.SlotRange)) {
 			log.Error("Mismatch migrating slot",

Original file line number	Diff line number	Diff line change
`@@ -339,7 +339,8 @@ func (c *ClusterChecker) tryUpdateMigrationStatus(ctx context.Context, clonedClu`
`339`	`339`	`continue`
`340`	`340`	`}`
`341`	`341`
`342`		`- // If there is no migration information on the source node or source node migratingslot is not eauqls shard, you need to clear the migration information on the controller.`
	`342`	`+ // If there is no migration information on the source node or the source node migration slot is not equal to the shard,`
	`343`	`+ // you need to clear the migration information on the controller.`
`343`	`344`	`if sourceNodeClusterInfo.MigratingSlot == nil \|\| (sourceNodeClusterInfo.MigratingSlot != nil &&`
`344`	`345`	`!sourceNodeClusterInfo.MigratingSlot.Equal(shard.MigratingSlot.SlotRange)) {`
`345`	`346`	`log.Error("Mismatch migrating slot",`