Add log when the keyspace group to which a keyspace belongs changed.

Signed-off-by: Bin Shi <[email protected]>
tikv · Jun 15, 2023 · a5e619b · a5e619b
1 parent cbfe681
commit a5e619b
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/client/tso_service_discovery.go b/client/tso_service_discovery.go
@@ -463,6 +463,14 @@ func (c *tsoServiceDiscovery) updateMember() error {
 		}
 	}
 
+	oldGroupID := c.GetKeyspaceGroupID()
+	if oldGroupID != keyspaceGroup.Id {
+		log.Info("[tso] the keyspace group changed",
+			zap.Uint32("keyspace-id", keyspaceGroup.Id),
+			zap.Uint32("new-keyspace-group-id", keyspaceGroup.Id),
+			zap.Uint32("old-keyspace-group-id", oldGroupID))
+	}
+
 	// Initialize the serving addresses from the returned keyspace group info.
 	primaryAddr := ""
 	secondaryAddrs := make([]string, 0)

diff --git a/tools/pd-tso-bench/main.go b/tools/pd-tso-bench/main.go
@@ -121,7 +121,7 @@ func bench(mainCtx context.Context) {
 	} else {
 		wg.Add((*concurrency) * (*clientNumber))
 		for i := 0; i < *clientNumber; i++ {
-			for i := 0; i < *concurrency; i++ {
+			for j := 0; j < *concurrency; j++ {
 				go reqWorker(ctx, pdClients, i, durCh)
 			}
 		}