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 dc9f8efa0b5845d5f431869781b631f601205d6b Author: jiashuo <[email protected]> AuthorDate: Thu Jun 16 15:23:55 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 21bdc38b..aa40eaaf 100644 --- a/admin-cli/executor/toolkits/tablemigrator/migrator.go +++ b/admin-cli/executor/toolkits/tablemigrator/migrator.go @@ -103,7 +103,7 @@ func checkUnConfirmedDecree(perfSessions map[string]*aggregate.PerfSession) erro if stats[0].Value > pendingMutationThreshold { completed = false - toolkits.LogInfo(fmt.Sprintf("%s has pending_mutations_count %d", addr, int64(stats[0].Value))) + toolkits.LogWarn(fmt.Sprintf("%s has pending_mutations_count %d", addr, int64(stats[0].Value))) break } } @@ -124,7 +124,7 @@ func checkDuplicatingQPS(perfSessions map[string]*aggregate.PerfSession, tableID for gpid, qps := range stats { if qps > 0 { completed = false - toolkits.LogInfo(fmt.Sprintf("%s[%s] still sending pending mutation %d", addr, gpid, int64(qps))) + toolkits.LogWarn(fmt.Sprintf("%s[%s] still sending pending mutation %d", addr, gpid, int64(qps))) break } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
