[incubator-pegasus] 23/25: update postion

[ji...@apache.org]

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 <js...@live.com>
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: commits-unsubscribe@pegasus.apache.org
For additional commands, e-mail: commits-help@pegasus.apache.org