This is an automated email from the ASF dual-hosted git repository. jiashuo pushed a commit to branch add-table-migrator in repository https://gitbox.apache.org/repos/asf/incubator-pegasus.git
commit 85e7236130ec948b516dc7dbb6c28f5fb88447e0 Author: jiashuo <[email protected]> AuthorDate: Thu Jun 16 15:22:16 2022 +0800 update postion --- admin-cli/executor/toolkits/tablemigrator/migrator.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/admin-cli/executor/toolkits/tablemigrator/migrator.go b/admin-cli/executor/toolkits/tablemigrator/migrator.go index 173ef5ca..21bdc38b 100644 --- a/admin-cli/executor/toolkits/tablemigrator/migrator.go +++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go @@ -34,8 +34,8 @@ func MigrateTable(client *executor.Client, table string, metaProxyZkAddrs string return err } - //3. check un-confirm decree if less 5k - toolkits.LogInfo(fmt.Sprintf("check un-confirm decree if less %f", pendingMutationThreshold)) + //3. check pending mutation count if less `pendingMutationThreshold` + toolkits.LogInfo(fmt.Sprintf("check pending mutation count if less %d", int64(pendingMutationThreshold))) nodes := client.Nodes.GetAllNodes(session.NodeTypeReplica) perfSessions := make(map[string]*aggregate.PerfSession) for _, n := range nodes { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
